Package com.google.apphosting.runtime.grpc

Class CallbackStreamObserver<ResponseT extends com.google.protobuf.Message>

java.lang.Object

com.google.apphosting.runtime.grpc.CallbackStreamObserver<ResponseT>

Type Parameters:

ResponseT - The proto2 message that gRPC will receive as a successful response.

All Implemented Interfaces:

io.grpc.stub.StreamObserver<ResponseT>

public class CallbackStreamObserver<ResponseT extends com.google.protobuf.Message>
extends Object
implements io.grpc.stub.StreamObserver<ResponseT>

gRPC client-side stream observer that converts the received RPC response into a call on the supplied AnyRpcCallback.

Method Summary

Modifier and Type	Method	Description
static <ResponseT extends com.google.protobuf.Message> CallbackStreamObserver<ResponseT>	of(GrpcClientContext clientContext, AnyRpcCallback<ResponseT> anyRpcCallback)	Returns a StreamObserver that will convert gRPC responses into calls on the given anyRpcCallback.
void	onCompleted()
void	onError(Throwable throwable)
void	onNext(ResponseT grpcResponse)

Methods inherited from class java.lang.Object

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

Method Details

of

public static <ResponseT extends com.google.protobuf.Message>
CallbackStreamObserver<ResponseT> of(GrpcClientContext clientContext,
 AnyRpcCallback<ResponseT> anyRpcCallback)

Returns a StreamObserver that will convert gRPC responses into calls on the given anyRpcCallback.

Parameters:

clientContext - the context that will be updated with success or failure details when the RPC completes

anyRpcCallback - the callback that will be invoked when the RPC completes

onNext

public void onNext(ResponseT grpcResponse)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<ResponseT extends com.google.protobuf.Message>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface io.grpc.stub.StreamObserver<ResponseT extends com.google.protobuf.Message>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<ResponseT extends com.google.protobuf.Message>