- Reference
Reference
The MongoDB RxJava Driver is built upon the MongoDB Async Driver
for detailed reference information see the official documentation.
MongoObservable
In RxJava Observable
is not an interface, so where the MongoDB Async Driver API follows a fluent interface pattern we return a
MongoObservable<T>
. The MongoObservable<T>
mirrors the underlying fluent API and provides two extra methods:
toObservable()
Returns an
Observable<T>
instance for the operation.subscribe(Subscriber<? super TResult> subscriber)
Subscribes to the
Observable
.
ObservableAdapter
Driver version 1.2.0 introduced the ObservableAdapter
interface.
This provides a simple way to adapt all Observable
s returned by the driver. On such use case might be to use a different Scheduler
after returning the results from MongoDB therefore freeing up the connection thread. ObservableAdapter
s can be applied at the
following levels:
An example of an ObservableAdapter
is as follows:
import rx.Schedulers;
MongoCollection adaptedCollection = collection.withObservableAdapter(new ObservableAdapter() {
@Override
public <T> Observable<T> adapt(final Observable<T> observable) {
return observable.observeOn(Schedulers.newThread());
}
});
Any computations on Observables
returned by the adaptedCollection
will use a new thread, rather than blocking the MongoDB Connection thread.