public final class ForwardingClientResponseObserver<ReqT,RespT>
extends java.lang.Object
implements org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.ClientResponseObserver<RespT,ReqT>
ClientResponseObserver
which delegates all StreamObserver
calls.
Used to wrap existing StreamObserver
s to be able to install an onReadyHandler
.
This is as thread-safe as the underlying stream observer that is being wrapped.
Modifier and Type | Method and Description |
---|---|
void |
beforeStart(org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.ClientCallStreamObserver<RespT> stream) |
static <ReqT,RespT> |
create(org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.StreamObserver<ReqT> inbound,
java.lang.Runnable onReadyHandler) |
void |
onCompleted() |
void |
onError(java.lang.Throwable t) |
void |
onNext(ReqT value) |
public static <ReqT,RespT> ForwardingClientResponseObserver<ReqT,RespT> create(org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.StreamObserver<ReqT> inbound, java.lang.Runnable onReadyHandler)
public void onNext(ReqT value)
onNext
in interface org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.StreamObserver<ReqT>
public void onError(java.lang.Throwable t)
onError
in interface org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.StreamObserver<ReqT>
public void onCompleted()
onCompleted
in interface org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.StreamObserver<ReqT>