Packages

implicit class ObservableFuture[T] extends AnyRef

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ObservableFuture
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

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

Value Members

  1. val observable: Observable[T]
  2. def toFuture(): Future[Seq[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 Observable and uses the Observable.collect[S]()* 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.