Class SpannerExecutorProxyGrpc.SpannerExecutorProxyStub (6.62.0)

public static final class SpannerExecutorProxyGrpc.SpannerExecutorProxyStub extends AbstractAsyncStub<SpannerExecutorProxyGrpc.SpannerExecutorProxyStub>

A stub to allow clients to do asynchronous rpc calls to service SpannerExecutorProxy.

Service that executes SpannerActions asynchronously.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > SpannerExecutorProxyGrpc.SpannerExecutorProxyStub

Inherited Members

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.getCallOptions()

io.grpc.stub.AbstractStub.getChannel()

io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)

io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)

io.grpc.stub.AbstractStub.withCompression(java.lang.String)

io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)

io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)

io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)

io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)

io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)

io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)

io.grpc.stub.AbstractStub.withWaitForReady()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

build(Channel channel, CallOptions callOptions)

protected SpannerExecutorProxyGrpc.SpannerExecutorProxyStub build(Channel channel, CallOptions callOptions)

Parameters
Name	Description
`channel`	`io.grpc.Channel`
`callOptions`	`io.grpc.CallOptions`

Returns
Type	Description
`SpannerExecutorProxyGrpc.SpannerExecutorProxyStub`

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

executeActionAsync(StreamObserver<SpannerAsyncActionResponse> responseObserver)

public StreamObserver<SpannerAsyncActionRequest> executeActionAsync(StreamObserver<SpannerAsyncActionResponse> responseObserver)

ExecuteActionAsync is a streaming call that starts executing a new Spanner action. For each request, the server will reply with one or more responses, but only the last response will contain status in the outcome. Responses can be matched to requests by action_id. It is allowed to have multiple actions in flight--in that case, actions are be executed in parallel.

Parameter
Name	Description
`responseObserver`	`io.grpc.stub.StreamObserver<SpannerAsyncActionResponse>`

Returns
Type	Description
`io.grpc.stub.StreamObserver<SpannerAsyncActionRequest>`