Class ReadRowsRetryingCallable (3.11.0) 

public final class ReadRowsRetryingCallable extends ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>

Inheritance

java.lang.Object > ServerStreamingCallable > ReadRowsRetryingCallable

Constructors

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

public ReadRowsRetryingCallable(ApiCallContext context, ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse> innerCallable, ScheduledRetryingExecutor<Void> executor, StreamResumptionStrategy<ReadRowsRequest,ReadRowsResponse> resumptionStrategyPrototype)
Parameters
Name Description
context ApiCallContext
innerCallable ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>
executor ScheduledRetryingExecutor<Void>
resumptionStrategyPrototype StreamResumptionStrategy<ReadRowsRequest,ReadRowsResponse>

Methods

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

public void call(ReadRowsRequest request, ResponseObserver<ReadRowsResponse> responseObserver, ApiCallContext context)
Parameters
Name Description
request ReadRowsRequest
responseObserver ResponseObserver<ReadRowsResponse>
context ApiCallContext
Overrides