implicit class SingleObservableFuture[T] extends AnyRef
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- SingleObservableFuture
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new SingleObservableFuture(obs: => SingleObservable[T])
Value Members
- val observable: SingleObservable[T]
- def toFuture(): Future[T]
Collects the Observable results and converts to a
scala.concurrent.Future.Collects the Observable results and converts to a
scala.concurrent.Future.Automatically subscribes to the
Observableand uses the Observable.head method to aggregate the results.- returns
a future representation of the whole Observable
- Note
If the Observable is large then this will consume lots of memory! If the underlying Observable is infinite this Observable will never complete.
- def toFutureOption(): Future[Option[T]]
Collects the Observable result and converts to a
scala.concurrent.Future.Collects the Observable result and converts to a
scala.concurrent.Future.- returns
a future representation of the Observable
This is the documentation for the MongoDB Scala driver.
Driver structure
The mongodb scala driver.
To get started you need a MongoClient instance, either from a connection string or via a org.mongodb.scala.MongoClientSettings.
Notable packages include: