Package org.apache.beam.sdk.fn.stream

Class ForwardingClientResponseObserver<ReqT,RespT>

java.lang.Object

org.apache.beam.sdk.fn.stream.ForwardingClientResponseObserver<ReqT,RespT>

All Implemented Interfaces:

org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.ClientResponseObserver<RespT,ReqT>, org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<ReqT>

public final class ForwardingClientResponseObserver<ReqT,RespT>
extends Object
implements org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.ClientResponseObserver<RespT,ReqT>

A ClientResponseObserver which delegates all StreamObserver calls.

Used to wrap existing StreamObservers to be able to install an onReadyHandler and a handler invoked when the stream terminates.

This is as thread-safe as the underlying stream observer that is being wrapped.

Method Summary

Modifier and Type	Method	Description
void	beforeStart(org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.ClientCallStreamObserver<RespT> stream)
static <ReqT, RespT> ForwardingClientResponseObserver<ReqT,RespT>	create(org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<ReqT> inbound, Runnable onReadyHandler)
static <ReqT, RespT> ForwardingClientResponseObserver<ReqT,RespT>	create(org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<ReqT> inbound, Runnable onReadyHandler, Runnable onDoneHandler)
void	onCompleted()
void	onError(Throwable t)
void	onNext(ReqT value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

public static <ReqT,
RespT>
ForwardingClientResponseObserver<ReqT,RespT> create(org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<ReqT> inbound,
 Runnable onReadyHandler)

create

public static <ReqT,
RespT>
ForwardingClientResponseObserver<ReqT,RespT> create(org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<ReqT> inbound,
 Runnable onReadyHandler,
 Runnable onDoneHandler)

onNext

public void onNext(ReqT value)

Specified by:

onNext in interface org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<ReqT>

onError

public void onError(Throwable t)

Specified by:

onError in interface org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<ReqT>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<ReqT>

beforeStart

public void beforeStart(org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.ClientCallStreamObserver<RespT> stream)

Specified by:

beforeStart in interface org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.ClientResponseObserver<ReqT,RespT>