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
    reactor.core.publisher.Flux<ChangeStreamEvent<T>>
    listen()
    Start listening to changes.

  • Method Details

    • listen

      reactor.core.publisher.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.