Package com.mongodb.reactivestreams.client

@NonNullApi 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.

Related Packages

Package	Description
com.mongodb.reactivestreams.client.gridfs	Contains the classes for supporting MongoDB's specification for storing very large files, GridFS.
com.mongodb.reactivestreams.client.vault	This package contains the Key Vault API

Class	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.
ListCollectionNamesPublisher	Publisher for listing collection names.
ListCollectionsPublisher<TResult>	Publisher interface for ListCollections.
ListDatabasesPublisher<TResult>	Publisher interface for ListDatabases.
ListIndexesPublisher<TResult>	Publisher interface for ListIndexes.
ListSearchIndexesPublisher<TResult>	A specific Publisher interface for listing Atlas Search indexes.
MapReducePublisher<TResult>	Deprecated. Superseded by aggregate
MongoClient	A client-side representation of a MongoDB cluster.
MongoClients	A factory for MongoClient instances.
MongoCluster	The client-side representation of a MongoDB cluster operations.
MongoCollection<TDocument>	The MongoCollection interface.
MongoDatabase	The MongoDatabase interface.
ReactiveContextProvider	A ContextProvider for reactive clients.