org.springframework.cloud.gcp.data.firestore.util

Class ObservableReactiveUtil

java.lang.Object

org.springframework.cloud.gcp.data.firestore.util.ObservableReactiveUtil

public final class ObservableReactiveUtil
extends Object

Converter from a gRPC async calls to Reactor primitives (Mono, Flux).

Since:

1.2

Author:

Dmitry Solomakha, Chengyuan Zhao

Method Summary

Modifier and Type	Method and Description
static <ResponseT,RequestT,T> reactor.core.publisher.Flux<T>	streamingBidirectionalCall(Function<io.grpc.stub.StreamObserver<ResponseT>,io.grpc.stub.StreamObserver<RequestT>> initialCall, reactor.core.publisher.Flux<List<T>> inputs, BiFunction<List<T>,ResponseT,RequestT> responseHandler) Opens a bi-directional streaming call.
static <ResponseT> reactor.core.publisher.Flux<ResponseT>	streamingCall(Consumer<io.grpc.stub.StreamObserver<ResponseT>> remoteCall) Invokes a lambda that issues a streaming call and directs the response to a Flux stream.
static <ResponseT> reactor.core.publisher.Mono<ResponseT>	unaryCall(Consumer<io.grpc.stub.StreamObserver<ResponseT>> remoteCall) Invokes a lambda that in turn issues a remote call, directing the response to a Mono stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

unaryCall

public static <ResponseT> reactor.core.publisher.Mono<ResponseT> unaryCall(Consumer<io.grpc.stub.StreamObserver<ResponseT>> remoteCall)

Invokes a lambda that in turn issues a remote call, directing the response to a Mono stream.

Type Parameters:

ResponseT - type of remote call response

Parameters:

remoteCall - lambda capable of invoking the correct remote call, making use of the Mono-converting StreamObserver implementation.

Returns:

Mono containing the response of the unary call.

streamingCall

public static <ResponseT> reactor.core.publisher.Flux<ResponseT> streamingCall(Consumer<io.grpc.stub.StreamObserver<ResponseT>> remoteCall)

Invokes a lambda that issues a streaming call and directs the response to a Flux stream.

Type Parameters:

ResponseT - response type

Parameters:

remoteCall - call to make

Returns:

Flux of response objects resulting from the streaming call.

streamingBidirectionalCall

public static <ResponseT,RequestT,T> reactor.core.publisher.Flux<T> streamingBidirectionalCall(Function<io.grpc.stub.StreamObserver<ResponseT>,io.grpc.stub.StreamObserver<RequestT>> initialCall,
                                                                                               reactor.core.publisher.Flux<List<T>> inputs,
                                                                                               BiFunction<List<T>,ResponseT,RequestT> responseHandler)

Opens a bi-directional streaming call.

Type Parameters:

ResponseT - type of objects streamed from the server

RequestT - type of objects q streamed to the server

T - type of input objects that will be wrapped in RequestT

Parameters:

initialCall - opens a bidirectional gRPC connection with the provided StreamObserver.

inputs - stream of objects to send to the server

responseHandler - processes responses streamed from the server

Returns:

A Flux of server responses