public static interface ReactiveFindOperation.TerminatingFind<T>
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<T> |
all()
Get all matching elements.
|
reactor.core.publisher.Mono<Long> |
count()
Get the number of matching elements.
|
reactor.core.publisher.Mono<Boolean> |
exists()
Check for the presence of matching elements.
|
reactor.core.publisher.Mono<T> |
first()
Get the first or no result.
|
reactor.core.publisher.Mono<T> |
one()
Get exactly zero or one result.
|
reactor.core.publisher.Flux<T> |
tail()
Get all matching elements using a
tailable cursor . |
reactor.core.publisher.Mono<T> one()
Mono.empty()
if no match found. Never null.IncorrectResultSizeDataAccessException
- if more than one match found.reactor.core.publisher.Mono<T> first()
Mono.empty()
if no match found. Never null.reactor.core.publisher.Flux<T> all()
reactor.core.publisher.Flux<T> tail()
tailable cursor
. The stream will
not be completed unless the Subscription
is
canceled
.
However, the stream may become dead, or invalid, if either the query returns no match or the cursor returns the
document at the "end" of the collection and then the application deletes that document.
A stream that is no longer in use must be Disposable.dispose()
disposed} otherwise the
streams will linger and exhaust resources. Flux
emitting converted objects.reactor.core.publisher.Mono<Long> count()
Mono
emitting total number of matching elements. Never null.reactor.core.publisher.Mono<Boolean> exists()
Mono
emitting true if at least one matching element exists. Never null.Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.