public static interface ReactiveChangeStreamOperation.ResumingChangeStream<T> extends ReactiveChangeStreamOperation.TerminatingChangeStream<T>
Modifier and Type | Method and Description |
---|---|
ReactiveChangeStreamOperation.TerminatingChangeStream<T> |
resumeAfter(Object token)
Resume the change stream after a given point.
|
ReactiveChangeStreamOperation.TerminatingChangeStream<T> |
resumeAt(Object token)
Resume the change stream at a given point.
|
ReactiveChangeStreamOperation.TerminatingChangeStream<T> |
startAfter(Object token)
Start the change stream after a given point.
|
listen
ReactiveChangeStreamOperation.TerminatingChangeStream<T> resumeAt(Object token)
token
- an Instant
or BsonTimestamp
ReactiveChangeStreamOperation.TerminatingChangeStream
.IllegalArgumentException
- if the given beacon is neither Instant
nor BsonTimestamp
.ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeAt(Instant)
,
ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeAt(BsonTimestamp)
ReactiveChangeStreamOperation.TerminatingChangeStream<T> resumeAfter(Object token)
token
- an Instant
or BsonTimestamp
ReactiveChangeStreamOperation.TerminatingChangeStream
.IllegalArgumentException
- if the given beacon not a BsonValue
.ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeAfter(BsonValue)
,
ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeToken(BsonValue)
ReactiveChangeStreamOperation.TerminatingChangeStream<T> startAfter(Object token)
token
- an Instant
or BsonTimestamp
ReactiveChangeStreamOperation.TerminatingChangeStream
.IllegalArgumentException
- if the given beacon not a BsonValue
.(BsonValue)
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.