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 [T] extends AnyVal

    Extension methods for Subscriber.

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

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

    Subscriber builder

  2. 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.

  3. def dump[A](prefix: String, out: PrintStream = System.out)(implicit s: Scheduler): Sync[A]

    Builds an Subscriber that just logs incoming events.

  4. 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.

  5. def fromReactiveSubscriber[T](subscriber: org.reactivestreams.Subscriber[T], subscription: Cancelable)(implicit s: Scheduler): Subscriber[T]

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

  6. def toReactiveSubscriber[T](source: Subscriber[T], bufferSize: Int): org.reactivestreams.Subscriber[T]

    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.

    bufferSize

    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

  7. def toReactiveSubscriber[T](subscriber: Subscriber[T]): org.reactivestreams.Subscriber[T]

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

  8. object Sync extends Serializable