Packages

abstract class Pipe[I, +O] extends Serializable

Represents a factory for an input/output channel for broadcasting input to multiple subscribers.

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

Instance Constructors

  1. new Pipe()

Abstract Value Members

  1. abstract def unicast: (Observer[I], Observable[O])

    Returns an input/output pair that can be used to push input to a single subscriber.

    Returns an input/output pair that can be used to push input to a single subscriber.

    This means that the returned observable should be subscribed at most once, otherwise the behavior is undefined.

    See also

    multicast for creating a safe observable that can be subscribed many times.

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  6. def concurrent(strategy: Synchronous[I], producerType: ProducerSide)(implicit s: Scheduler): (Sync[I], Observable[O])

    Returns an input/output pair with an input that can be used synchronously and concurrently (without back-pressure or multi-threading issues) to push signals to multiple subscribers.

    Returns an input/output pair with an input that can be used synchronously and concurrently (without back-pressure or multi-threading issues) to push signals to multiple subscribers.

    strategy

    is the OverflowStrategy used for the underlying multi-producer/single-consumer buffer

    producerType

    specifies the ChannelType.ProducerSide, which configures the type of the producer, for performance optimization; can be multi producer (the default) or single producer

  7. def concurrent(strategy: Synchronous[I])(implicit s: Scheduler): (Sync[I], Observable[O])

    Returns an input/output pair with an input that can be used synchronously and concurrently (without back-pressure or multi-threading issues) to push signals to multiple subscribers.

    Returns an input/output pair with an input that can be used synchronously and concurrently (without back-pressure or multi-threading issues) to push signals to multiple subscribers.

    strategy

    is the OverflowStrategy used for the underlying multi-producer/single-consumer buffer

  8. def concurrent(implicit s: Scheduler): (Sync[I], Observable[O])

    Returns an input/output pair with an input that can be used synchronously and concurrently (without back-pressure or multi-threading issues) to push signals to multiple subscribers.

  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def liftByOperator[B](op: Operator[O, B]): Pipe[I, B]
  15. def multicast(implicit s: Scheduler): (Observer[I], Observable[O])

    Returns an input/output pair that can be used to push input to multiple subscribers.

  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  19. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  20. def toString(): String
    Definition Classes
    AnyRef → Any
  21. final def transform[B](f: (Observable[O]) => Observable[B]): Pipe[I, B]

    Transforms the source using the given transformer function.

  22. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  23. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped