public final class 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.
Flow control with the underlying CallStreamObserver is handled with a Phaser
which waits for advancement of the phase if the CallStreamObserver is not ready. Callers
are expected to advance the Phaser whenever the underlying CallStreamObserver
Constructor and Description