Package io.grpc.stub
Class ClientCalls.BlockingResponseStream.QueuingListener
java.lang.Object
io.grpc.ClientCall.Listener<T>
io.grpc.stub.ClientCalls.StartableListener<T>
io.grpc.stub.ClientCalls.BlockingResponseStream.QueuingListener
- Enclosing class:
ClientCalls.BlockingResponseStream<T>
private final class ClientCalls.BlockingResponseStream.QueuingListener
extends ClientCalls.StartableListener<T>
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class io.grpc.ClientCall.Listener
onReady
-
Field Details
-
done
private boolean done
-
-
Constructor Details
-
QueuingListener
QueuingListener()
-
-
Method Details
-
onHeaders
Description copied from class:ClientCall.Listener
The response headers have been received. Headers always precede messages.Since
Metadata
is not thread-safe, the caller must not access (read or write)headers
after this point.- Overrides:
onHeaders
in classClientCall.Listener<T>
- Parameters:
headers
- containing metadata sent by the server at the start of the response.
-
onMessage
Description copied from class:ClientCall.Listener
A response message has been received. May be called zero or more times depending on whether the call response is empty, a single message or a stream of messages.- Overrides:
onMessage
in classClientCall.Listener<T>
- Parameters:
value
- returned by the server
-
onClose
Description copied from class:ClientCall.Listener
The ClientCall has been closed. Any additional calls to theClientCall
will not be processed by the server. No further receiving will occur and no further notifications will be made.Since
Metadata
is not thread-safe, the caller must not access (read or write)trailers
after this point.If
status
returns false forStatus.isOk()
, then the call failed. An additional block of trailer metadata may be received at the end of the call from the server. An emptyMetadata
object is passed if no trailers are received.This method should not throw. If this method throws, there is no way to be notified of the exception. Implementations should therefore be careful of exceptions which can accidentally leak resources.
- Overrides:
onClose
in classClientCall.Listener<T>
- Parameters:
status
- the result of the remote call.trailers
- metadata provided at call completion.
-
onStart
void onStart()- Specified by:
onStart
in classClientCalls.StartableListener<T>
-