public static interface ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T> extends ReactiveChangeStreamOperation.ResumingChangeStream<T>, ReactiveChangeStreamOperation.TerminatingChangeStream<T>
Modifier and Type | Method and Description |
---|---|
<R> ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<R> |
as(Class<R> resultType)
Define the target type fields should be mapped to.
|
ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T> |
filter(Aggregation by)
Use an
Aggregation to filter matching events. |
ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T> |
filter(CriteriaDefinition by)
Use a
critera to filter matching events via an
MatchOperation . |
resumeAfter, resumeAt, startAfter
listen
ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T> filter(Aggregation by)
Aggregation
to filter matching events.by
- must not be null.ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection
.IllegalArgumentException
- if the given Aggregation
is null.ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T> filter(CriteriaDefinition by)
critera
to filter matching events via an
MatchOperation
.by
- must not be null.ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection
.IllegalArgumentException
- if the given CriteriaDefinition
is null.<R> ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<R> as(Class<R> resultType)
R
- result type.resultType
- must not be null.ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection
.IllegalArgumentException
- if resultType is null.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.