com.mongodb.reactivestreams.client.MongoCollection |
|
com.mongodb.reactivestreams.client.MongoDatabase |
|
org.reactivestreams.Publisher |
completableResult |
RX wrapper for SingleResultCallback fun completableResult(callback: (SingleResultCallback<Void>) -> Unit): Completable |
maybeResult |
RX wrapper for SingleResultCallback fun <T> maybeResult(callback: (SingleResultCallback<T>) -> Unit): Maybe<T> |
singleResult |
RX wrapper for SingleResultCallback fun <T> singleResult(callback: (SingleResultCallback<T>) -> Unit): Single<T> |