org.apache.beam.sdk.fn.stream (Apache Beam 2.5.0)

Interface Summary
Interface	Description
DataStreams.OutputChunkConsumer<T>	A callback which is invoked whenever the `DataStreams.outbound(org.apache.beam.sdk.fn.stream.DataStreams.OutputChunkConsumer<com.google.protobuf.ByteString>)` `OutputStream` becomes full.
StreamObserverFactory.StreamObserverClientFactory<RequestT,ResponseT>	A factory which creates `StreamObservers` based on the input stream observer.

Class Summary
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 `ByteString`s as a single input stream and `DataStreams.outbound(OutputChunkConsumer)` treats a single `OutputStream` as multiple `ByteString`s.
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>	An adapter which converts an `InputStream` to an `Iterator` of `T` values using the specified `Coder`.
DataStreams.ElementDelimitedOutputStream	An adapter which wraps an `DataStreams.OutputChunkConsumer` as an `OutputStream`.
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`.

Package org.apache.beam.sdk.fn.stream Description

gRPC stream management.