org.apache.beam.sdk.fn.stream

Class BufferingStreamObserver<T>

java.lang.Object

org.apache.beam.sdk.fn.stream.BufferingStreamObserver<T>

All Implemented Interfaces:

io.grpc.stub.StreamObserver<T>

@ThreadSafe
public final class BufferingStreamObserver<T>
extends java.lang.Object
implements io.grpc.stub.StreamObserver<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 becomes ready.

Constructor Summary

Constructors

Constructor and Description
BufferingStreamObserver(java.util.concurrent.Phaser phaser, io.grpc.stub.CallStreamObserver<T> outboundObserver, java.util.concurrent.ExecutorService executor, int bufferSize)

Method Summary

Modifier and Type	Method and Description
int	getBufferSize()
void	onCompleted()
void	onError(java.lang.Throwable t)
void	onNext(T value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BufferingStreamObserver

public BufferingStreamObserver(java.util.concurrent.Phaser phaser,
                               io.grpc.stub.CallStreamObserver<T> outboundObserver,
                               java.util.concurrent.ExecutorService executor,
                               int bufferSize)

Method Detail

onNext

public void onNext(T value)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<T>

onError

public void onError(java.lang.Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<T>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<T>

getBufferSize

public int getBufferSize()