Package org.springframework.data.mongodb.core

Interface ReactiveChangeStreamOperation.TerminatingChangeStream<T>

All Known Subinterfaces:

ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T>, ReactiveChangeStreamOperation.ReactiveChangeStream<T>, ReactiveChangeStreamOperation.ResumingChangeStream<T>

Enclosing interface:

ReactiveChangeStreamOperation

public static interface ReactiveChangeStreamOperation.TerminatingChangeStream<T>

Compose change stream execution by calling one of the terminating methods.

Method Summary

Modifier and Type	Method	Description
Flux<ChangeStreamEvent<T>>	listen()	Start listening to changes.

Method Details

listen

Flux<ChangeStreamEvent<T>> listen()

Start listening to changes. The stream will not be completed unless the Subscription is canceled.
However, the stream may become dead, or invalid, if all watched collections, databases are dropped.