Packages

object ConnectableObservable extends Serializable

Source
ConnectableObservable.scala
Linear Supertypes
Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConnectableObservable
  2. Serializable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def cacheUntilConnect[A, B](source: Observable[A], subject: Subject[A, B])(implicit s: Scheduler): ConnectableObservable[B]

    Creates a ConnectableObservable that takes elements from source and caches them until the call to connect() happens.

    Creates a ConnectableObservable that takes elements from source and caches them until the call to connect() happens. After that the events are piped through the given subject to the final subscribers.

    Annotations
    @UnsafeBecauseImpure()
  2. def multicast[A, B](source: Observable[A], recipe: Pipe[A, B])(implicit s: Scheduler): ConnectableObservable[B]

    Builds a ConnectableObservable for the given observable source and a given Pipe.

    Builds a ConnectableObservable for the given observable source and a given Pipe.

    Annotations
    @UnsafeBecauseImpure()
  3. def unsafeMulticast[A, B](source: Observable[A], subject: Subject[A, B])(implicit s: Scheduler): ConnectableObservable[B]

    Builds a ConnectableObservable for the given observable source and a given Subject.

    Builds a ConnectableObservable for the given observable source and a given Subject.

    Annotations
    @UnsafeProtocol() @UnsafeBecauseImpure()