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.
Since:
2.2
Author:
Christoph Strobl

  • 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.