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