public class GrpcRequestAggregationStreamObserver extends GrpcRequestAbstractStreamObserver
consumer, endpoint, exchange, headers, responseObserver
Constructor and Description |
---|
GrpcRequestAggregationStreamObserver(GrpcEndpoint endpoint,
GrpcConsumer consumer,
io.grpc.stub.StreamObserver<Object> responseObserver,
Map<String,Object> headers) |
Modifier and Type | Method and Description |
---|---|
void |
onCompleted() |
void |
onError(Throwable t) |
void |
onNext(Object request) |
public GrpcRequestAggregationStreamObserver(GrpcEndpoint endpoint, GrpcConsumer consumer, io.grpc.stub.StreamObserver<Object> responseObserver, Map<String,Object> headers)
Apache Camel