Package | Description |
---|---|
io.grpc.stub |
API for the Stub layer.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClientResponseObserver<ReqT,RespT>
Specialization of
StreamObserver implemented by clients in order to interact with the
advanced features of a call such as flow-control. |
Modifier and Type | Class and Description |
---|---|
class |
CallStreamObserver<V>
A refinement of StreamObserver provided by the GRPC runtime to the application that allows for
more complex interactions with call behavior.
|
class |
ClientCallStreamObserver<V>
A refinement of
CallStreamObserver that allows for lower-level interaction with
client calls. |
class |
ServerCallStreamObserver<V>
A refinement of
CallStreamObserver to allows for interaction with call
cancellation events on the server side. |
Modifier and Type | Method and Description |
---|---|
static <ReqT,RespT> |
ClientCalls.asyncBidiStreamingCall(ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a bidirectional-streaming call.
|
static <ReqT,RespT> |
ClientCalls.asyncClientStreamingCall(ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a client-streaming call returning a
StreamObserver for the request messages. |
static <T> StreamObserver<T> |
ServerCalls.asyncUnimplementedStreamingCall(MethodDescriptor<?,?> methodDescriptor,
StreamObserver<?> responseObserver)
Sets unimplemented status for streaming call.
|
Modifier and Type | Method and Description |
---|---|
static <ReqT,RespT> |
ClientCalls.asyncBidiStreamingCall(ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a bidirectional-streaming call.
|
static <ReqT,RespT> |
ClientCalls.asyncClientStreamingCall(ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a client-streaming call returning a
StreamObserver for the request messages. |
static <ReqT,RespT> |
ClientCalls.asyncServerStreamingCall(ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
Executes a server-streaming call with a response
StreamObserver . |
static <ReqT,RespT> |
ClientCalls.asyncUnaryCall(ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
Executes a unary call with a response
StreamObserver . |
static <T> StreamObserver<T> |
ServerCalls.asyncUnimplementedStreamingCall(MethodDescriptor<?,?> methodDescriptor,
StreamObserver<?> responseObserver)
Sets unimplemented status for streaming call.
|
static void |
ServerCalls.asyncUnimplementedUnaryCall(MethodDescriptor<?,?> methodDescriptor,
StreamObserver<?> responseObserver)
Sets unimplemented status for method on given response stream for unary call.
|
Copyright © 2018. All rights reserved.