public interface StreamListener
Stream
events. It is guaranteed to only have one concurrent callback at a
time.Modifier and Type | Interface and Description |
---|---|
static interface |
StreamListener.MessageProducer
A producer for deframed gRPC messages.
|
Modifier and Type | Method and Description |
---|---|
void |
messagesAvailable(StreamListener.MessageProducer producer)
Called upon receiving a message from the remote end-point.
|
void |
onReady()
This indicates that the transport is now capable of sending additional messages
without requiring excessive buffering internally.
|
void messagesAvailable(StreamListener.MessageProducer producer)
Implementations must eventually drain the provided producer
StreamListener.MessageProducer
completely by invoking StreamListener.MessageProducer.next()
to obtain deframed messages until the
producer returns null.
This method should return quickly, as the same thread may be used to process other streams.
producer
- supplier of deframed messages.void onReady()
Copyright © 2018. All rights reserved.