Interface FindPublisherPreparer
- All Superinterfaces:
ReadPreferenceAware
Simple callback interface to allow customization of a
FindPublisher
.- Author:
- Mark Paluch, Christoph Strobl, Konstantin Volivach
-
Field Summary
Modifier and TypeFieldDescriptionstatic final FindPublisherPreparer
DefaultFindPublisherPreparer
just passing on the givenFindPublisher
. -
Method Summary
Modifier and TypeMethodDescriptiondefault com.mongodb.ReadPreference
default com.mongodb.reactivestreams.client.FindPublisher<org.bson.Document>
initiateFind
(com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> collection, Function<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>, com.mongodb.reactivestreams.client.FindPublisher<org.bson.Document>> find) Apply query specific settings toMongoCollection
and initiate a find operation returning aFindPublisher
via the givenfind
function.com.mongodb.reactivestreams.client.FindPublisher<org.bson.Document>
prepare
(com.mongodb.reactivestreams.client.FindPublisher<org.bson.Document> findPublisher) Prepare the given cursor (apply limits, skips and so on).Methods inherited from interface org.springframework.data.mongodb.core.ReadPreferenceAware
hasReadPreference
-
Field Details
-
NO_OP_PREPARER
DefaultFindPublisherPreparer
just passing on the givenFindPublisher
.- Since:
- 2.2
-
-
Method Details
-
prepare
com.mongodb.reactivestreams.client.FindPublisher<org.bson.Document> prepare(com.mongodb.reactivestreams.client.FindPublisher<org.bson.Document> findPublisher) Prepare the given cursor (apply limits, skips and so on). Returns the prepared cursor.- Parameters:
findPublisher
- must not be null.
-
initiateFind
default com.mongodb.reactivestreams.client.FindPublisher<org.bson.Document> initiateFind(com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> collection, Function<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>, com.mongodb.reactivestreams.client.FindPublisher<org.bson.Document>> find) Apply query specific settings toMongoCollection
and initiate a find operation returning aFindPublisher
via the givenfind
function.- Parameters:
collection
- must not be null.find
- must not be null.- Returns:
- never null.
- Throws:
IllegalArgumentException
- if one of the required arguments is null.- Since:
- 2.2
-
getReadPreference
- Specified by:
getReadPreference
in interfaceReadPreferenceAware
- Returns:
- the
ReadPreference
to apply or null if none defined. - Since:
- 2.2
-