Reference documentation and code samples for the Cloud Bigtable Client class ResumableStream.
User stream which handles failure from upstream, retries if necessary and provides single retrying user stream.
Methods
__construct
Constructs a resumable stream.
Parameters | |
---|---|
Name | Description |
apiFunction |
callable
Function to execute to get server stream. Function signature
should match: |
argumentFunction |
callable
Function which returns the argument to be used while
calling |
retryFunction |
callable
Function which determines whether to retry or not. |
retries |
int
[optional] Number of times to retry. Defaults to |
readAll
Starts executing the call and reading elements from server stream.
Returns | |
---|---|
Type | Description |
Generator |
getIterator
Returns | |
---|---|
Type | Description |
Generator |
isRetryable
Checks if code is retryable or not.
Parameter | |
---|---|
Name | Description |
code |
int
Code to check. |
Returns | |
---|---|
Type | Description |
bool |
Constants
DEFAULT_MAX_RETRIES
Value: 3