org.apache.beam.sdk.fn.stream

Interface StreamObserverFactory.StreamObserverClientFactory<RequestT,ResponseT>

Type Parameters:

RequestT - The type of message sent to the inbound stream

ResponseT - They type of messages sent over the outbound stream

Enclosing class:

StreamObserverFactory

public static interface StreamObserverFactory.StreamObserverClientFactory<RequestT,ResponseT>

A factory which creates StreamObservers based on the input stream observer.

For example, this could be used to

Method Summary

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<ResponseT>	outboundObserverFor(io.grpc.stub.StreamObserver<RequestT> inboundObserver)

Method Detail

outboundObserverFor

io.grpc.stub.StreamObserver<ResponseT> outboundObserverFor(io.grpc.stub.StreamObserver<RequestT> inboundObserver)