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 Details
-
all
reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult> all()Remove all documents matching.- Returns:
Mono
emitting theDeleteResult
. 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,ApplicationEvent
s will be published for each and every delete operation.- Returns:
- empty
Flux
if no match found. Never null.
-