Subscriber

Type Members

implicit final class Extensions[T] extends AnyVal

Extension methods for Subscriber.
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

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
object Sync extends Serializable
def apply[T](observer: Observer[T], scheduler: Scheduler): Subscriber[T]

Subscriber builder
final def asInstanceOf[T0]: T0

Definition Classes
Any
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.
def clone(): AnyRef

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

Builds an Subscriber that just logs incoming events.
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.
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
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.
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
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
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.
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Docs: trait Subscriber | package observers

object Subscriber extends Serializable

Type Members

implicit final class Extensions[T] extends AnyVal

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

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

object Sync extends Serializable

def apply[T](observer: Observer[T], scheduler: Scheduler): Subscriber[T]

final def asInstanceOf[T0]: T0

def canceled[A](implicit s: Scheduler): Sync[A]

def clone(): AnyRef

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

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

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

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

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

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

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

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped