Mongo Scala Driver - org.mongodb.scala.ObservableImplicits.ScalaObservable (original) (raw)

implicit class ScalaObservable[T] extends AnyRef

 

Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. ScalaObservable

2. AnyRef

3. Any

4. Hide All

5. Show All

Visibility

1. Public
2. Protected

Instance Constructors

1.  new ScalaObservable(obs: => Observable[T])

Value Members

1.  final def !=(arg0: Any): Boolean
2.  final def ##(): Int
3.  final def ==(arg0: Any): Boolean
4.  def andThen[U](pf: PartialFunction[Try[T], U]): Observable[T]
5.  final def asInstanceOf[T0]: T0
6.  def clone(): AnyRef
7.  def collect[S](): SingleObservable[Seq[T]]
8.  final def eq(arg0: AnyRef): Boolean
9.  def equals(arg0: AnyRef): Boolean
10.  def fallbackTo[U >: T](that: Observable[U]): Observable[U]
11.  def filter(predicate: (T) => Boolean): Observable[T]
12.  def finalize(): Unit
13.  def flatMap[S](mapFunction: (T) => Observable[S]): Observable[S]
14.  def foldLeft[S](initialValue: S)(accumulator: (S, T) => S): SingleObservable[S]
15.  def foreach[U](doOnEach: (T) => U): Unit
16.  final def getClass(): Class[_ <: AnyRef]
17.  def hashCode(): Int
18.  def head(): Future[T]
19.  def headOption(): Future[Option[T]]
20.  final def isInstanceOf[T0]: Boolean
21.  def map[S](mapFunction: (T) => S): Observable[S]
22.  final def ne(arg0: AnyRef): Boolean
23.  final def notify(): Unit
24.  final def notifyAll(): Unit
25.  val observable: Observable[T]
26.  def observeOn(context: ExecutionContext): Observable[T]
27.  def recover[U >: T](pf: PartialFunction[Throwable, U]): Observable[U]
28.  def recoverWith[U >: T](pf: PartialFunction[Throwable, Observable[U]]): Observable[U]
29.  def subscribe(doOnNext: (T) => Any, doOnError: (Throwable) => Any, doOnComplete: () => Any): Unit
30.  def subscribe(doOnError: (Throwable) => Any, doOnComplete: () => Any): Unit
31.  def subscribe(doOnNext: (T) => Any, doOnError: (Throwable) => Any): Unit
32.  def subscribe(doOnNext: (T) => Any): Unit
33.  final def synchronized[T0](arg0: => T0): T0
34.  def toFuture(): Future[Seq[T]]
35.  def toString(): String
36.  def transform[S](mapFunction: (T) => S, errorMapFunction: (Throwable) => Throwable): Observable[S]
37.  final def wait(): Unit
38.  final def wait(arg0: Long, arg1: Int): Unit
39.  final def wait(arg0: Long): Unit
40.  final def withFilter(p: (T) => Boolean): Observable[T]
41.  def zip[U](that: Observable[U]): Observable[(T, U)]

Ungrouped