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.