CallOptions.ServerCallHandler for a bidi streaming method of the service.StreamObserver for the request messages.ServerCallHandler for a client streaming method of the service.StreamObserver.ServerCallHandler for a server streaming method of the service.StreamObserver.ServerCallHandler for a unary call method of the service.stub.withInterceptors(newAttachHeadersInterceptor(...)) instead.ClientCallStreamObserver for the outbound stream.Iterator over the
response stream.Iterator over the
response stream.ClientCallStreamObserver.stub.withInterceptors(newCaptureMetadataInterceptor()) instead.CallStreamObserver that allows for lower-level interaction with
client calls.StreamObserver implemented by clients in order to interact with the
advanced features of a call such as flow-control.Iterator to the target CallStreamObserver while properly
accounting for outbound flow-control.Iterable to the target CallStreamObserver while properly
accounting for outbound flow-control.StreamObserver.onNext(Object) has completed.StreamObserver.onNext(Object) unless it is request()ed.StreamObserver.onNext(Object) unless it is request()ed.ListenableFuture to the response.CallOptions of the stub.true when the call is cancelled and the server is encouraged to abort
processing to save resources, since the client will not be processing any further methods.true, indicates that the observer is capable of sending additional messages
without requiring excessive buffering internally.true, indicates that the observer is capable of sending additional messages
without requiring excessive buffering internally.true, indicates that the observer is capable of sending additional messages
without requiring excessive buffering internally.count more messages to be delivered to the 'inbound'
StreamObserver.count more messages to be delivered to the 'inbound'
StreamObserver.count more messages to be delivered to the 'inbound'
StreamObserver.RpcMethod contains a limited subset of information about the RPC to assist
Java Annotation Processors.ServerCallHandlers to application service implementation,
meant to be used by the generated code.CallStreamObserver to allows for interaction with call
cancellation events on the server side.StreamObserver.onNext(V).StreamObserver.onNext(V).StreamObserver.onNext(V).Runnable to be called if the call is cancelled and the server is encouraged to
abort processing to save resources, since the client will not process any further messages.Runnable to be executed when the call is closed cleanly from the server's
point of view: either StreamObserver.onCompleted() or StreamObserver.onError(Throwable) has been called,
all the messages and trailing metadata have been sent and the stream has been closed.Runnable that will be executed every time the stream CallStreamObserver.isReady() state
changes from false to true.Runnable that will be executed every time the stream ClientCallStreamObserver.isReady() state
changes from false to true.Runnable that will be executed every time the stream ServerCallStreamObserver.isReady() state
changes from false to true.StreamObserver and it's common subclasses like
CallStreamObserver.duration from now.ManagedChannelBuilder.executor(java.util.concurrent.Executor).ClientInterceptor via the CallOptions parameter.