ResT
- type of the response messageReqT
- type of the request message@NotThreadSafe public class DataMessageServerRequestObserver<ReqT,ResT> extends DataMessageMarshallerProvider<ReqT,ResT> implements io.grpc.stub.StreamObserver<ResT>
StreamObserver
that handles raw data buffers.Constructor and Description |
---|
DataMessageServerRequestObserver(io.grpc.stub.StreamObserver<ResT> observer,
DataMessageMarshaller<ReqT> requestMarshaller,
DataMessageMarshaller<ResT> responseMarshaller) |
Modifier and Type | Method and Description |
---|---|
void |
onCompleted() |
void |
onError(Throwable t) |
void |
onNext(ResT value) |
getRequestMarshaller, getResponseMarshaller
public DataMessageServerRequestObserver(io.grpc.stub.StreamObserver<ResT> observer, DataMessageMarshaller<ReqT> requestMarshaller, DataMessageMarshaller<ResT> responseMarshaller)
observer
- the original response observerrequestMarshaller
- the marshaller for the requestresponseMarshaller
- the marshaller for the responsepublic void onNext(ResT value)
onNext
in interface io.grpc.stub.StreamObserver<ResT>
public void onError(Throwable t)
onError
in interface io.grpc.stub.StreamObserver<ResT>
public void onCompleted()
onCompleted
in interface io.grpc.stub.StreamObserver<ResT>
Copyright © 2023. All Rights Reserved.