Package | Description |
---|---|
com.mongodb.async.client |
This packages contains classes for the new async client
|
Modifier and Type | Field and Description |
---|---|
private Observer<? super TResult> |
AbstractSubscription.observer |
Modifier and Type | Method and Description |
---|---|
void |
Observable.subscribe(Observer<? super TResult> observer)
Request
Observable to start streaming data. |
Constructor and Description |
---|
AbstractSubscription(Observer<? super TResult> observer) |
FlatteningSingleResultCallbackSubscription(Block<SingleResultCallback<java.util.List<TResult>>> block,
Observer<? super TResult> observer) |
MongoIterableSubscription(MongoIterable<TResult> mongoIterable,
Observer<? super TResult> observer) |
SingleResultCallbackSubscription(Block<SingleResultCallback<TResult>> block,
Observer<? super TResult> observer) |