hera.client.stream

Class GrpcStreamObserverAdaptor<RpcModelT,DomainModelT>

java.lang.Object

hera.client.stream.GrpcStreamObserverAdaptor<RpcModelT,DomainModelT>

All Implemented Interfaces:

io.grpc.stub.StreamObserver<RpcModelT>

public class GrpcStreamObserverAdaptor<RpcModelT,DomainModelT>
extends java.lang.Object
implements io.grpc.stub.StreamObserver<RpcModelT>

Field Summary

Fields

Modifier and Type	Field and Description
protected io.grpc.Context.CancellableContext	context
protected ModelConverter<DomainModelT,RpcModelT>	converter
protected StreamObserver<DomainModelT>	delegate
protected ExceptionConverter<RpcException>	exceptionConverter
protected org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
GrpcStreamObserverAdaptor()

Method Summary

Modifier and Type	Method and Description
void	onCompleted()
void	onError(java.lang.Throwable t)
void	onNext(RpcModelT value)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final transient org.slf4j.Logger logger

exceptionConverter

protected final ExceptionConverter<RpcException> exceptionConverter

context

protected final io.grpc.Context.CancellableContext context

delegate

protected final StreamObserver<DomainModelT> delegate

converter

protected final ModelConverter<DomainModelT,RpcModelT> converter

Constructor Detail

GrpcStreamObserverAdaptor

public GrpcStreamObserverAdaptor()

Method Detail

onNext

public void onNext(RpcModelT value)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<RpcModelT>

onError

public void onError(java.lang.Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<RpcModelT>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<RpcModelT>