Packages

object Subscriber extends Serializable

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

Type Members

  1. implicit final class Extensions[A] extends AnyVal

    Extension methods for Subscriber.

  2. trait Sync[-A] extends Subscriber[A] with Observer.Sync[A]

    A Subscriber.Sync is a Subscriber whose onNext signal is synchronous (i.e.

    A Subscriber.Sync is a Subscriber whose onNext signal is synchronous (i.e. the upstream observable doesn't need to wait on a Future in order to decide whether to send the next event or not).

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. def apply[A](observer: Observer[A], scheduler: Scheduler): Subscriber[A]

    Subscriber builder

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def canceled[A](implicit s: Scheduler): Sync[A]

    Helper for building an empty subscriber that doesn't do anything, but that returns Stop on onNext.

  7. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  8. def dump[A](prefix: String, out: PrintStream = System.out)(implicit s: Scheduler): Sync[A]

    Builds an Subscriber that just logs incoming events.

  9. def empty[A](implicit s: Scheduler): Sync[A]

    Helper for building an empty subscriber that doesn't do anything, besides logging errors in case they happen.

  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  12. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  13. def fromReactiveSubscriber[A](subscriber: org.reactivestreams.Subscriber[A], subscription: Cancelable)(implicit s: Scheduler): Subscriber[A]

    Given an org.reactivestreams.Subscriber as defined by the Reactive Streams specification, it builds an Subscriber instance compliant with the Monix Rx implementation.

  14. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  21. def toReactiveSubscriber[A](source: Subscriber[A], requestCount: Int): org.reactivestreams.Subscriber[A]

    Transforms the source Subscriber into a org.reactivestreams.Subscriber instance as defined by the Reactive Streams specification.

    Transforms the source Subscriber into a org.reactivestreams.Subscriber instance as defined by the Reactive Streams specification.

    requestCount

    a strictly positive number, representing the size of the buffer used and the number of elements requested on each cycle when communicating demand, compliant with the reactive streams specification

  22. def toReactiveSubscriber[A](subscriber: Subscriber[A]): org.reactivestreams.Subscriber[A]

    Transforms the source Subscriber into a org.reactivestreams.Subscriber instance as defined by the Reactive Streams specification.

  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  27. object Sync extends Serializable

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped