ReadChangeStreamResumptionStrategy (Google Cloud Bigtable Parent 2.27.2 API)

java.lang.Object
- com.google.cloud.bigtable.data.v2.stub.changestream.ReadChangeStreamResumptionStrategy<ChangeStreamRecordT>

All Implemented Interfaces:

com.google.api.gax.retrying.StreamResumptionStrategy<ReadChangeStreamRequest,ChangeStreamRecordT>
```
@InternalApi
public class ReadChangeStreamResumptionStrategy<ChangeStreamRecordT>
extends Object
implements com.google.api.gax.retrying.StreamResumptionStrategy<ReadChangeStreamRequest,ChangeStreamRecordT>
```
An implementation of a StreamResumptionStrategy for change stream records. This class tracks the continuation token and upon retry can build a request to resume the stream from where it left off.
This class is considered an internal implementation detail and not meant to be used by applications.

Constructor Summary

Constructors
Constructor Description

ReadChangeStreamResumptionStrategy(ChangeStreamRecordAdapter<ChangeStreamRecordT> changeStreamRecordAdapter)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`canResume()`
`com.google.api.gax.retrying.StreamResumptionStrategy<ReadChangeStreamRequest,ChangeStreamRecordT>`	`createNew()`
`ReadChangeStreamRequest`	`getResumeRequest(ReadChangeStreamRequest originalRequest)`
`ChangeStreamRecordT`	`processResponse(ChangeStreamRecordT response)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ReadChangeStreamResumptionStrategy
```
public ReadChangeStreamResumptionStrategy(ChangeStreamRecordAdapter<ChangeStreamRecordT> changeStreamRecordAdapter)
```
- Method Detail
  - canResume
```
public boolean canResume()
```
    Specified by:
    
    canResume in interface com.google.api.gax.retrying.StreamResumptionStrategy<ReadChangeStreamRequest,ChangeStreamRecordT>
  - createNew
```
public com.google.api.gax.retrying.StreamResumptionStrategy<ReadChangeStreamRequest,ChangeStreamRecordT> createNew()
```
    Specified by:
    
    createNew in interface com.google.api.gax.retrying.StreamResumptionStrategy<ReadChangeStreamRequest,ChangeStreamRecordT>
  - processResponse
```
public ChangeStreamRecordT processResponse(ChangeStreamRecordT response)
```
    Specified by:
    
    processResponse in interface com.google.api.gax.retrying.StreamResumptionStrategy<ReadChangeStreamRequest,ChangeStreamRecordT>
  - getResumeRequest
```
public ReadChangeStreamRequest getResumeRequest(ReadChangeStreamRequest originalRequest)
```
    Given a request, this implementation will narrow that request to include data changes that come after token.
    
    Specified by:
    
    getResumeRequest in interface com.google.api.gax.retrying.StreamResumptionStrategy<ReadChangeStreamRequest,ChangeStreamRecordT>