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
Interface Summary Interface Description AggregatePublisher<TResult>Publisher for aggregate. ChangeStreamPublisher<TResult>Iterable for change streams. ClientSessionA 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. MongoClientA client-side representation of a MongoDB cluster. MongoCollection<TDocument>The MongoCollection interface. MongoDatabaseThe MongoDatabase interface.
Class Summary Class Description MongoClientsA factory for MongoClient instances.