| Interface | Description |
|---|---|
| DataStreams.OutputChunkConsumer<T> | Deprecated
Used as a temporary placeholder until implementation of
DataStreams.outbound(OutputChunkConsumer). |
| StreamObserverFactory.StreamObserverClientFactory<RequestT,ResponseT> |
A factory which creates
StreamObservers based on the input stream
observer. |
| Class | Description |
|---|---|
| AdvancingPhaser |
A
Phaser which never terminates. |
| BufferingStreamObserver<T> |
A thread safe
StreamObserver which uses a bounded queue to pass elements to a processing
thread responsible for interacting with the underlying CallStreamObserver. |
| DataStreams |
DataStreams.inbound(Iterator) treats multiple ByteStrings as a single input stream and
DataStreams.outbound(OutputChunkConsumer) treats a single OutputStream as multiple
ByteStrings. |
| DataStreams.BlockingQueueIterator<T> |
Allows for one or more writing threads to append values to this iterator while one reading
thread reads values.
|
| DataStreams.DataStreamDecoder<T> | |
| DirectStreamObserver<T> |
A
StreamObserver which uses synchronization on the underlying
CallStreamObserver to provide thread safety. |
| ForwardingClientResponseObserver<ReqT,RespT> |
A
ClientResponseObserver which delegates all StreamObserver calls. |
| StreamObserverFactory |
Creates factories which determine an underlying
StreamObserver implementation
to use in to interact with fn execution APIs. |
| SynchronizedStreamObserver<V> |
A
StreamObserver which provides synchronous access access to an underlying StreamObserver. |