Package io.grpc.alts.internal
Class HandshakerServiceGrpc.HandshakerServiceStub
java.lang.Object
io.grpc.stub.AbstractStub<HandshakerServiceGrpc.HandshakerServiceStub>
io.grpc.stub.AbstractAsyncStub<HandshakerServiceGrpc.HandshakerServiceStub>
io.grpc.alts.internal.HandshakerServiceGrpc.HandshakerServiceStub
- Enclosing class:
HandshakerServiceGrpc
public static final class HandshakerServiceGrpc.HandshakerServiceStub
extends io.grpc.stub.AbstractAsyncStub<HandshakerServiceGrpc.HandshakerServiceStub>
A stub to allow clients to do asynchronous rpc calls to service HandshakerService.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
HandshakerServiceStub
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) -
Method Summary
Modifier and TypeMethodDescriptionbuild
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) io.grpc.stub.StreamObserver
<HandshakerReq> doHandshake
(io.grpc.stub.StreamObserver<HandshakerResp> responseObserver) Handshaker service accepts a stream of handshaker request, returning a stream of handshaker response.Methods inherited from class io.grpc.stub.AbstractAsyncStub
newStub, newStub
Methods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Constructor Details
-
HandshakerServiceStub
private HandshakerServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
-
-
Method Details
-
build
protected HandshakerServiceGrpc.HandshakerServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
build
in classio.grpc.stub.AbstractStub<HandshakerServiceGrpc.HandshakerServiceStub>
-
doHandshake
public io.grpc.stub.StreamObserver<HandshakerReq> doHandshake(io.grpc.stub.StreamObserver<HandshakerResp> responseObserver) Handshaker service accepts a stream of handshaker request, returning a stream of handshaker response. Client is expected to send exactly one message with either client_start or server_start followed by one or more messages with next. Each time client sends a request, the handshaker service expects to respond. Client does not have to wait for service's response before sending next request.
-