Method Detail

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