Simplification

champel · champel · commit feedf8b32450 · 2023-02-17T14:36:58.000+01:00
Signed-off-by: Sergio &lt;champel@gmail.com&gt;
diff --git a/sdk/src/main/java/io/dapr/client/DaprClientGrpc.java b/sdk/src/main/java/io/dapr/client/DaprClientGrpc.java
@@ -181,7 +181,7 @@ public Mono<Void> publishEvent(PublishEventRequest request) {
         envelopeBuilder.putAllMetadata(metadata);
       }
 
-      return Mono.deferContextual(Mono::just).flatMap(
+      return Mono.deferContextual(
           context ->
               this.<Empty>createMono(
                   it -> intercept(context, asyncStub).publishEvent(envelopeBuilder.build(), it)

Original file line number	Diff line number	Diff line change
`@@ -181,7 +181,7 @@ public Mono<Void> publishEvent(PublishEventRequest request) {`
`181`	`181`	`envelopeBuilder.putAllMetadata(metadata);`
`182`	`182`	`}`
`183`	`183`
`184`		`- return Mono.deferContextual(Mono::just).flatMap(`
	`184`	`+ return Mono.deferContextual(`
`185`	`185`	`context ->`
`186`	`186`	`this.<Empty>createMono(`
`187`	`187`	`it -> intercept(context, asyncStub).publishEvent(envelopeBuilder.build(), it)`