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>	Deprecated. Superseded by aggregate
MongoClient	A client-side representation of a MongoDB cluster.
MongoCollection<TDocument>	The MongoCollection interface.
MongoDatabase	The MongoDatabase interface.
ReactiveContextProvider	A ContextProvider for reactive clients.

Class Summary

Class	Description
MongoClients	A factory for MongoClient instances.