public class DelegationWriteHandler extends Object implements io.grpc.stub.StreamObserver<WriteRequest>
Constructor and Description |
---|
DelegationWriteHandler(WorkerProcess workerProcess,
io.grpc.stub.StreamObserver<WriteResponse> responseObserver,
AuthenticatedUserInfo userInfo,
boolean domainSocketEnabled) |
Modifier and Type | Method and Description |
---|---|
void |
onCancel()
Handles cancel event from the client.
|
void |
onCompleted() |
void |
onError(Throwable t) |
void |
onNext(WriteRequest request) |
public DelegationWriteHandler(WorkerProcess workerProcess, io.grpc.stub.StreamObserver<WriteResponse> responseObserver, AuthenticatedUserInfo userInfo, boolean domainSocketEnabled)
workerProcess
- the worker process instanceresponseObserver
- the response observer of the gRPC streamuserInfo
- the authenticated user infodomainSocketEnabled
- whether using a domain socketpublic void onNext(WriteRequest request)
onNext
in interface io.grpc.stub.StreamObserver<WriteRequest>
public void onError(Throwable t)
onError
in interface io.grpc.stub.StreamObserver<WriteRequest>
public void onCompleted()
onCompleted
in interface io.grpc.stub.StreamObserver<WriteRequest>
public void onCancel()
Copyright © 2023. All Rights Reserved.