Interface ReactiveRemoveOperation.TerminatingRemove<T>

All Known Subinterfaces:
ReactiveRemoveOperation.ReactiveRemove<T>, ReactiveRemoveOperation.RemoveWithCollection<T>, ReactiveRemoveOperation.RemoveWithQuery<T>
Enclosing interface:
ReactiveRemoveOperation

public static interface ReactiveRemoveOperation.TerminatingRemove<T>
Compose remove execution by calling one of the terminating methods.
  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult>
    all()
    Remove all documents matching.
    reactor.core.publisher.Flux<T>
    Remove and return all matching documents.
  • Method Details

    • all

      reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult> all()
      Remove all documents matching.
      Returns:
      Mono emitting the DeleteResult. Never null.
    • findAndRemove

      reactor.core.publisher.Flux<T> findAndRemove()
      Remove and return all matching documents.
      NOTE The entire list of documents will be fetched before sending the actual delete commands. Also, ApplicationEvents will be published for each and every delete operation.
      Returns:
      empty Flux if no match found. Never null.