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.ServerCallHandler
s 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.