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