Uses of Interface
io.grpc.stub.StreamObserver
-
Packages that use StreamObserver Package Description io.grpc.stub API for the Stub layer. -
-
Uses of StreamObserver in io.grpc.stub
Subinterfaces of StreamObserver in io.grpc.stub Modifier and Type Interface Description interface
ClientResponseObserver<ReqT,RespT>
Specialization ofStreamObserver
implemented by clients in order to interact with the advanced features of a call such as flow-control.Classes in io.grpc.stub that implement StreamObserver Modifier and Type Class Description class
CallStreamObserver<V>
A refinement of StreamObserver provided by the GRPC runtime to the application (the client or the server) that allows for more complex interactions with call behavior.class
ClientCallStreamObserver<ReqT>
A refinement ofCallStreamObserver
that allows for lower-level interaction with client calls.class
ServerCallStreamObserver<RespT>
A refinement ofCallStreamObserver
to allows for interaction with call cancellation events on the server side.Methods in io.grpc.stub that return StreamObserver Modifier and Type Method Description static <ReqT,RespT>
StreamObserver<ReqT>ClientCalls. asyncBidiStreamingCall(io.grpc.ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)
Executes a bidirectional-streaming call.static <ReqT,RespT>
StreamObserver<ReqT>ClientCalls. asyncClientStreamingCall(io.grpc.ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)
Executes a client-streaming call returning aStreamObserver
for the request messages.static <ReqT> StreamObserver<ReqT>
ServerCalls. asyncUnimplementedStreamingCall(io.grpc.MethodDescriptor<?,?> methodDescriptor, StreamObserver<?> responseObserver)
Sets unimplemented status for streaming call.StreamObserver<ReqT>
ServerCalls.BidiStreamingMethod. invoke(StreamObserver<RespT> responseObserver)
StreamObserver<ReqT>
ServerCalls.ClientStreamingMethod. invoke(StreamObserver<RespT> responseObserver)
Methods in io.grpc.stub with parameters of type StreamObserver Modifier and Type Method Description static <ReqT,RespT>
StreamObserver<ReqT>ClientCalls. asyncBidiStreamingCall(io.grpc.ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)
Executes a bidirectional-streaming call.static <ReqT,RespT>
StreamObserver<ReqT>ClientCalls. asyncClientStreamingCall(io.grpc.ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)
Executes a client-streaming call returning aStreamObserver
for the request messages.static <ReqT,RespT>
voidClientCalls. asyncServerStreamingCall(io.grpc.ClientCall<ReqT,RespT> call, ReqT req, StreamObserver<RespT> responseObserver)
Executes a server-streaming call with a responseStreamObserver
.static <ReqT,RespT>
voidClientCalls. asyncUnaryCall(io.grpc.ClientCall<ReqT,RespT> call, ReqT req, StreamObserver<RespT> responseObserver)
Executes a unary call with a responseStreamObserver
.static <ReqT> StreamObserver<ReqT>
ServerCalls. asyncUnimplementedStreamingCall(io.grpc.MethodDescriptor<?,?> methodDescriptor, StreamObserver<?> responseObserver)
Sets unimplemented status for streaming call.static void
ServerCalls. asyncUnimplementedUnaryCall(io.grpc.MethodDescriptor<?,?> methodDescriptor, StreamObserver<?> responseObserver)
Sets unimplemented status for method on given response stream for unary call.StreamObserver<ReqT>
ServerCalls.BidiStreamingMethod. invoke(StreamObserver<RespT> responseObserver)
StreamObserver<ReqT>
ServerCalls.ClientStreamingMethod. invoke(StreamObserver<RespT> responseObserver)
void
ServerCalls.ServerStreamingMethod. invoke(ReqT request, StreamObserver<RespT> responseObserver)
void
ServerCalls.UnaryMethod. invoke(ReqT request, StreamObserver<RespT> responseObserver)
-