public final class ReadRowsRetryingCallable extends ServerStreamingCallable<ReadRowsRequest,ReadRowsResponse>
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 |