Class ReadRowsRetryingCallable (3.11.0) 

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

Inheritance

java.lang.Object > ServerStreamingCallable > ReadRowsRetryingCallable

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