Skip to content

Commit 49a4b03

Browse files
committed
Fix rebase conflicts
Signed-off-by: Artur Ciocanu <artur.ciocanu@gmail.com>
1 parent 425958d commit 49a4b03

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

sdk/src/main/java/io/dapr/client/DaprClientImpl.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -511,9 +511,9 @@ public <T> Flux<T> subscribeToTopic(String pubsubName, String topic, TypeRef<T>
511511
* {@inheritDoc}
512512
*/
513513
@Override
514-
public <T> Flux<T> subscribeToEvents(String pubsubName, String topic, TypeRef<T> type, Map<String, String> metadata) {
515-
DaprProtos.SubscribeTopicEventsRequestInitialAlpha1.Builder initialRequestBuilder =
516-
DaprProtos.SubscribeTopicEventsRequestInitialAlpha1.newBuilder()
514+
public <T> Flux<T> subscribeToTopic(String pubsubName, String topic, TypeRef<T> type, Map<String, String> metadata) {
515+
DaprPubsubProtos.SubscribeTopicEventsRequestInitialAlpha1.Builder initialRequestBuilder =
516+
DaprPubsubProtos.SubscribeTopicEventsRequestInitialAlpha1.newBuilder()
517517
.setTopic(topic)
518518
.setPubsubName(pubsubName);
519519

0 commit comments

Comments
 (0)