Observer

Type Members

implicit final class Extensions[T] extends AnyVal

Extension methods for Observer.
trait Sync[-T] extends Observer[T]

An Observer.Sync is an Observer that signals demand to upstream synchronously (i.e.
An Observer.Sync is an Observer that signals demand to upstream synchronously (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).
Can be used for optimizations.

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
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

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

Builds an Observer that just logs incoming events.
def empty[A](implicit r: UncaughtExceptionReporter): Sync[A]

Helper for building an empty observer 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 feed[T](target: Observer[T], subscription: BooleanCancelable, iterator: Iterator[T])(implicit s: Scheduler): Future[Ack]

Feeds the Observer instance with elements from the given Iterator, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.
Feeds the Observer instance with elements from the given Iterator, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.
target
is the observer that will get the events
subscription
is a BooleanCancelable that will be queried for its cancellation status, but only on asynchronous boundaries, and when it is seen as being isCanceled, streaming is stopped
iterator
is the collection of items to push downstream
def feed[T](target: Observer[T], iterator: Iterator[T])(implicit s: Scheduler): Future[Ack]

Feeds the Observer instance with elements from the given Iterator, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.
Feeds the Observer instance with elements from the given Iterator, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.
target
is the observer that will get the events
iterator
is the collection of items to push downstream
def feed[T](target: Observer[T], subscription: BooleanCancelable, iterable: Iterable[T])(implicit s: Scheduler): Future[Ack]

Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.
Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.
target
is the observer that will get the events
subscription
is a BooleanCancelable that will be queried for its cancellation status, but only on asynchronous boundaries, and when it is seen as being isCanceled, streaming is stopped
iterable
is the collection of items to push downstream
def feed[T](target: Observer[T], iterable: Iterable[T])(implicit s: Scheduler): Future[Ack]

Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.
Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.
target
is the observer that will get the events
iterable
is the collection of items to push downstream
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def fromReactiveSubscriber[T](subscriber: Subscriber[T], subscription: Cancelable)(implicit s: Scheduler): Observer[T]

Given an org.reactivestreams.Subscriber as defined by the Reactive Streams specification, it builds an Observer 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](observer: Observer[T], bufferSize: Int)(implicit s: Scheduler): Subscriber[T]

Transforms the source Observer into a org.reactivestreams.Subscriber instance as defined by the Reactive Streams specification.
Transforms the source Observer 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](observer: Observer[T])(implicit s: Scheduler): Subscriber[T]

Transforms the source Observer 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 Observer | package reactive

object Observer extends Serializable

Type Members

implicit final class Extensions[T] extends AnyVal

trait Sync[-T] extends Observer[T]

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

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

def empty[A](implicit r: UncaughtExceptionReporter): Sync[A]

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def feed[T](target: Observer[T], subscription: BooleanCancelable, iterator: Iterator[T])(implicit s: Scheduler): Future[Ack]

def feed[T](target: Observer[T], iterator: Iterator[T])(implicit s: Scheduler): Future[Ack]

def feed[T](target: Observer[T], subscription: BooleanCancelable, iterable: Iterable[T])(implicit s: Scheduler): Future[Ack]

def feed[T](target: Observer[T], iterable: Iterable[T])(implicit s: Scheduler): Future[Ack]

def finalize(): Unit

def fromReactiveSubscriber[T](subscriber: Subscriber[T], subscription: Cancelable)(implicit s: Scheduler): Observer[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](observer: Observer[T], bufferSize: Int)(implicit s: Scheduler): Subscriber[T]

def toReactiveSubscriber[T](observer: Observer[T])(implicit s: Scheduler): 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