Package com.couchbase.client.core.protostellar

Class CoreProtostellarAccessorsStreaming

java.lang.Object

com.couchbase.client.core.protostellar.CoreProtostellarAccessorsStreaming

public class CoreProtostellarAccessorsStreaming
extends Object

Used to generically handle the core functionality of sending a GRPC request over Protostellar and handling the streaming response.

Can handle any streaming setup, e.g. query, search, etc.

For single-request-single-response situations, .

Method Summary

Modifier and Type	Method	Description
static <TGrpcRequest, TGrpcResponse> CoreAsyncResponse<List<TGrpcResponse>>	async(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, BiConsumer<ProtostellarEndpoint,com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall, Function<Throwable,ProtostellarRequestBehaviour> convertException)
static <TGrpcRequest, TGrpcResponse> List<TGrpcResponse>	blocking(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, BiConsumer<ProtostellarEndpoint,com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall, Function<Throwable,ProtostellarRequestBehaviour> convertException)
static <TGrpcRequest, TGrpcResponse> Flux<TGrpcResponse>	reactive(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, BiConsumer<ProtostellarEndpoint,com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall, Function<Throwable,ProtostellarRequestBehaviour> convertException)

Methods inherited from class java.lang.Object

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

Method Details

blocking

public static <TGrpcRequest,
TGrpcResponse>
List<TGrpcResponse> blocking(CoreProtostellar core,
 ProtostellarRequest<TGrpcRequest> request,
 BiConsumer<ProtostellarEndpoint,com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall,
 Function<Throwable,ProtostellarRequestBehaviour> convertException)

async

public static <TGrpcRequest,
TGrpcResponse>
CoreAsyncResponse<List<TGrpcResponse>> async(CoreProtostellar core,
 ProtostellarRequest<TGrpcRequest> request,
 BiConsumer<ProtostellarEndpoint,com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall,
 Function<Throwable,ProtostellarRequestBehaviour> convertException)

reactive

public static <TGrpcRequest,
TGrpcResponse>
Flux<TGrpcResponse> reactive(CoreProtostellar core,
 ProtostellarRequest<TGrpcRequest> request,
 BiConsumer<ProtostellarEndpoint,com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall,
 Function<Throwable,ProtostellarRequestBehaviour> convertException)