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 |