ResT
- the type of response sent by the serverpublic abstract class UpstreamAwareStreamObserver<ResT> extends Object implements io.grpc.stub.ClientResponseObserver<Object,ResT>
ClientCallStreamObserver
Constructor and Description |
---|
UpstreamAwareStreamObserver() |
Modifier and Type | Method and Description |
---|---|
void |
beforeStart(io.grpc.stub.ClientCallStreamObserver<Object> requestStream) |
protected void |
completeRequestStream()
Completes the request steam related to this stream observer.
|
io.grpc.stub.ClientCallStreamObserver<?> |
getRequestStream()
Returns the request stream observer which allows interaction with the client stream.
|
public void beforeStart(io.grpc.stub.ClientCallStreamObserver<Object> requestStream)
public io.grpc.stub.ClientCallStreamObserver<?> getRequestStream()
protected void completeRequestStream()
Copyright © 2010–2023. All rights reserved.