Package 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
    Description
    org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<RespT>
    outboundObserverFor(org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<ReqT> inboundObserver)
     

  • Method Details

    • outboundObserverFor

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