@FunctionalInterface
public static interface OutboundObserverFactory.BasicFactory<ReqT,RespT>
Modifier and Type | Method and Description |
---|---|
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<RespT> |
outboundObserverFor(org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<ReqT> inboundObserver) |