Package com.oracle.coherence.grpc.proxy.common

Class ProxyServiceChannel.ForwardingStreamObserver<Resp extends com.google.protobuf.Message>

java.lang.Object

com.oracle.coherence.grpc.proxy.common.ProxyServiceChannel.ForwardingStreamObserver<Resp>

Type Parameters:

Resp - the type of the protocol responses

All Implemented Interfaces:

io.grpc.stub.StreamObserver<Resp>

Enclosing class:

ProxyServiceChannel

protected class ProxyServiceChannel.ForwardingStreamObserver<Resp extends com.google.protobuf.Message>
extends Object
implements io.grpc.stub.StreamObserver<Resp>

A StreamObserver used to handle responses from the GrpcServiceProtocol and convert them to a ProxyResponse to send down the channel.

Constructor Summary

Constructors

Constructor	Description
ForwardingStreamObserver(long nId)	Create a ProxyServiceChannel.ForwardingStreamObserver.

Method Summary

Modifier and Type	Method	Description
void	onCompleted()
void	onError(Throwable t)
void	onNext(Resp response)

Methods inherited from class java.lang.Object

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

Constructor Details

ForwardingStreamObserver

public ForwardingStreamObserver(long nId)

Create a ProxyServiceChannel.ForwardingStreamObserver.

Parameters:

nId - the identifier of the request message

Method Details

onNext

public void onNext(Resp response)

Specified by:

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

onError

public void onError(Throwable t)

Specified by:

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

onCompleted

public void onCompleted()

Specified by:

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