Class ReadRowsRetryingCallable (2.36.0)

public final class ReadRowsRetryingCallable extends ServerStreamingCallable<Storage.ReadRowsRequest,Storage.ReadRowsResponse>

Inheritance

java.lang.Object > ServerStreamingCallable > ReadRowsRetryingCallable

Inherited Members

ServerStreamingCallable.all()

ServerStreamingCallable.blockingServerStreamingCall(RequestT)

ServerStreamingCallable.blockingServerStreamingCall(RequestT,ApiCallContext)

ServerStreamingCallable.call(RequestT)

ServerStreamingCallable.call(RequestT,ApiCallContext)

ServerStreamingCallable.call(RequestT,ResponseObserver<ResponseT>)

ServerStreamingCallable.call(RequestT,ResponseObserver<ResponseT>,ApiCallContext)

ServerStreamingCallable.first()

ServerStreamingCallable.serverStreamingCall(RequestT,ApiStreamObserver<ResponseT>)

ServerStreamingCallable.serverStreamingCall(RequestT,ApiStreamObserver<ResponseT>,ApiCallContext)

ServerStreamingCallable.withDefaultCallContext(ApiCallContext)

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)

Constructors

ReadRowsRetryingCallable(ApiCallContext context, ServerStreamingCallable<Storage.ReadRowsRequest,Storage.ReadRowsResponse> innerCallable, ScheduledRetryingExecutor<Void> executor, StreamResumptionStrategy<Storage.ReadRowsRequest,Storage.ReadRowsResponse> resumptionStrategyPrototype)

public ReadRowsRetryingCallable(ApiCallContext context, ServerStreamingCallable<Storage.ReadRowsRequest,Storage.ReadRowsResponse> innerCallable, ScheduledRetryingExecutor<Void> executor, StreamResumptionStrategy<Storage.ReadRowsRequest,Storage.ReadRowsResponse> resumptionStrategyPrototype)

Parameters
Name	Description
`context`	`ApiCallContext`
`innerCallable`	`ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>`
`executor`	`ScheduledRetryingExecutor<Void>`
`resumptionStrategyPrototype`	`StreamResumptionStrategy<ReadRowsRequest,ReadRowsResponse>`

Methods

call(Storage.ReadRowsRequest request, ResponseObserver<Storage.ReadRowsResponse> responseObserver, ApiCallContext context)

public void call(Storage.ReadRowsRequest request, ResponseObserver<Storage.ReadRowsResponse> responseObserver, ApiCallContext context)

Parameters
Name	Description
`request`	`Storage.ReadRowsRequest`
`responseObserver`	`ResponseObserver<ReadRowsResponse>`
`context`	`ApiCallContext`

Overrides

ServerStreamingCallable<RequestT,ResponseT>.call(RequestT request, ResponseObserver<ResponseT> responseObserver, ApiCallContext context)