Package org.apache.beam.sdk.fn.test

Class TestStreams.Builder<T>

java.lang.Object

org.apache.beam.sdk.fn.test.TestStreams.Builder<T>

Enclosing class:

TestStreams

public static class TestStreams.Builder<T>
extends Object

A builder for a test CallStreamObserver that performs various callbacks.

Method Summary

Modifier and Type	Method	Description
org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.CallStreamObserver<T>	build()
TestStreams.Builder<T>	withIsReady(Supplier<Boolean> isReady)	Returns a new TestStreams.Builder like this one with the specified CallStreamObserver.isReady() callback.
TestStreams.Builder<T>	withOnCompleted(Runnable onCompleted)	Returns a new TestStreams.Builder like this one with the specified StreamObserver.onCompleted() callback.
TestStreams.Builder<T>	withOnError(Runnable onError)	Returns a new TestStreams.Builder like this one with the specified StreamObserver.onError(java.lang.Throwable) callback.
TestStreams.Builder<T>	withOnError(Consumer<Throwable> onError)	Returns a new TestStreams.Builder like this one with the specified StreamObserver.onError(java.lang.Throwable) consumer.

Methods inherited from class java.lang.Object

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

Method Details

withIsReady

public TestStreams.Builder<T> withIsReady(Supplier<Boolean> isReady)

Returns a new TestStreams.Builder like this one with the specified CallStreamObserver.isReady() callback.

withOnCompleted

public TestStreams.Builder<T> withOnCompleted(Runnable onCompleted)

Returns a new TestStreams.Builder like this one with the specified StreamObserver.onCompleted() callback.

withOnError

public TestStreams.Builder<T> withOnError(Runnable onError)

Returns a new TestStreams.Builder like this one with the specified StreamObserver.onError(java.lang.Throwable) callback.

withOnError

public TestStreams.Builder<T> withOnError(Consumer<Throwable> onError)

Returns a new TestStreams.Builder like this one with the specified StreamObserver.onError(java.lang.Throwable) consumer.

build

public org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.CallStreamObserver<T> build()