@Test public void unaryCallReturnsSingleValue() { Mono<Integer> mono = ObservableReactiveUtil.unaryCall(observer -> { observer.onNext(42); observer.onCompleted(); }); StepVerifier.create(mono) .expectNext(42) .verifyComplete(); }
public static <ResponseT> Mono<ResponseT> unaryCall( Consumer<StreamObserver<ResponseT>> remoteCall) { return Mono.create(sink -> remoteCall.accept(new UnaryStreamObserver(sink))); }
ObservableReactiveUtil { public static <ResponseT> Mono<ResponseT> unaryCall( Consumer<StreamObserver<ResponseT>> remoteCall) { return Mono.create(sink -> remoteCall.accept(new UnaryStreamObserver(sink))); } }
ObservableReactiveUtil { public static <ResponseT> Mono<ResponseT> unaryCall( Consumer<StreamObserver<ResponseT>> remoteCall) { return Mono.create(sink -> remoteCall.accept(new UnaryStreamObserver(sink))); }  }
ObservableReactiveUtil { public static <ResponseT> Mono<ResponseT> unaryCall( Consumer<StreamObserver<ResponseT>> remoteCall) { return Mono.create(sink -> remoteCall.accept(new UnaryStreamObserver(sink))); }  static Mono<ResponseT> unaryCall(
      Consumer<StreamObserver<ResponseT>> remoteCall); static Flux<ResponseT> streamingCall(
      Consumer<StreamObserver<ResponseT>> remoteCall); }
ObservableReactiveUtil { public static <ResponseT> Mono<ResponseT> unaryCall( Consumer<StreamObserver<ResponseT>> remoteCall) { return Mono.create(sink -> remoteCall.accept(new UnaryStreamObserver(sink))); }  static Mono<ResponseT> unaryCall(
      Consumer<StreamObserver<ResponseT>> remoteCall); static Flux<ResponseT> streamingCall(
      Consumer<StreamObserver<ResponseT>> remoteCall);  }