Package com.mongodb.reactivestreams.client
This packages contains classes for the reactive stream client implementation.
All API Publishers are
cold,
meaning that nothing happens until they are subscribed to.
So just creating a Publisher won’t cause any network IO.
It’s not until Publisher.subscribe(org.reactivestreams.Subscriber) is called that the driver executes the
operation.
All API Publishers are unicast.
Each Subscription to a Publisher relates to a single MongoDB operation and its
Subscriber will receive its own specific set of results.
-
Interface Summary Interface Description AggregatePublisher<TResult> Publisher for aggregate.ChangeStreamPublisher<TResult> Iterable for change streams.ClientSession A client session that supports transactions.DistinctPublisher<TResult> Iterable for distinct.FindPublisher<TResult> Publisher interface for find.ListCollectionsPublisher<TResult> Publisher interface for ListCollections.ListDatabasesPublisher<TResult> Publisher interface for ListDatabases.ListIndexesPublisher<TResult> Publisher interface for ListIndexes.MapReducePublisher<TResult> Publisher for map reduce.MongoClient A client-side representation of a MongoDB cluster.MongoCollection<TDocument> The MongoCollection interface.MongoDatabase The MongoDatabase interface. -
Class Summary Class Description MongoClients A factory for MongoClient instances.