org.apache.beam.sdk.fn.stream

Interface OutboundObserverFactory.BasicFactory<ReqT,RespT>

Enclosing class:

OutboundObserverFactory

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface OutboundObserverFactory.BasicFactory<ReqT,RespT>

Creates an outbound observer for the given inbound observer.

Method Summary

Modifier and Type	Method and Description
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.StreamObserver<RespT>	outboundObserverFor(org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.StreamObserver<ReqT> inboundObserver)

Method Detail

outboundObserverFor

org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.StreamObserver<RespT> outboundObserverFor(org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.StreamObserver<ReqT> inboundObserver)