public interface ReactiveChangeStreamOperation
ReactiveChangeStreamOperation
allows creation and execution of reactive MongoDB
Change Stream operations in a fluent API style. TypedAggregation
used for filtering. By default, the
originating domainType is also used for mapping back the result from the Document
.
However, it is possible to define an different returnType via as
.
changeStream(Jedi.class)
.watchCollection("star-wars")
.filter(where("operationType").is("insert"))
.resumeAt(Instant.now())
.listen();
Modifier and Type | Interface and Description |
---|---|
static interface |
ReactiveChangeStreamOperation.ChangeStreamWithCollection<T>
Collection override (optional).
|
static interface |
ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T>
Provide a filter for limiting results (optional).
|
static interface |
ReactiveChangeStreamOperation.ChangeStreamWithOptions<T>
Provide some options.
|
static interface |
ReactiveChangeStreamOperation.ReactiveChangeStream<T>
ReactiveChangeStreamOperation.ReactiveChangeStream provides methods for constructing change stream operations in a fluent way. |
static interface |
ReactiveChangeStreamOperation.ResumingChangeStream<T>
Resume a change stream.
|
static interface |
ReactiveChangeStreamOperation.TerminatingChangeStream<T>
Compose change stream execution by calling one of the terminating methods.
|
Modifier and Type | Method and Description |
---|---|
<T> ReactiveChangeStreamOperation.ReactiveChangeStream<T> |
changeStream(Class<T> domainType)
Start creating a change stream operation for the given domainType watching all collections within the
database.
|
<T> ReactiveChangeStreamOperation.ReactiveChangeStream<T> changeStream(Class<T> domainType)
collection
and/or
filter
.domainType
- must not be null. Use Document
to obtain raw elements.ReactiveChangeStreamOperation.ReactiveChangeStream
. Never null.IllegalArgumentException
- if domainType is null.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.