org.apache.beam.sdk.fn.stream

Class DirectStreamObserver<T>

java.lang.Object

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

All Implemented Interfaces:

io.grpc.stub.StreamObserver<T>

@ThreadSafe
public final class DirectStreamObserver<T>
extends java.lang.Object
implements io.grpc.stub.StreamObserver<T>

A StreamObserver which uses synchronization on the underlying CallStreamObserver to provide thread safety.

Flow control with the underlying CallStreamObserver is handled with a Phaser which waits for advancement of the phase if the CallStreamObserver is not ready. Creator is expected to advance the Phaser whenever the underlying CallStreamObserver becomes ready.

Constructor Summary

Constructors

Constructor and Description
DirectStreamObserver(java.util.concurrent.Phaser phaser, io.grpc.stub.CallStreamObserver<T> outboundObserver)

Method Summary

Modifier and Type	Method and Description
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

DirectStreamObserver

public DirectStreamObserver(java.util.concurrent.Phaser phaser,
                            io.grpc.stub.CallStreamObserver<T> outboundObserver)

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>