Package

monix

reactive

Permalink

package reactive

Visibility
  1. Public
  2. All

Type Members

  1. trait Consumer[-In, +R] extends (Observable[In]) ⇒ Task[R] with Serializable

    Permalink

    The Consumer is a specification of how to consume an observable.

    The Consumer is a specification of how to consume an observable.

    It is a factory of subscribers with a completion callback attached, being effectively a way to transform observables into tasks for less error prone consuming of streams.

  2. sealed abstract class MulticastStrategy[+A] extends Serializable

    Permalink

    The MulticastStrategy specifies the strategy for building data-sources that are shared between multiple subscribers.

    The MulticastStrategy specifies the strategy for building data-sources that are shared between multiple subscribers.

    By default observables tend to be cold.

  3. sealed abstract class Notification[+T] extends Serializable

    Permalink

    Used by Observable.materialize.

  4. trait Observable[+A] extends ObservableLike[A, Observable]

    Permalink

    The Observable type that implements the Reactive Pattern.

    The Observable type that implements the Reactive Pattern.

    Provides methods of subscribing to the Observable and operators for combining observable sources, filtering, modifying, throttling, buffering, error handling and others.

    See the available documentation at: https://monix.io

  5. trait Observer[-T] extends Serializable

    Permalink

    The Observer from the Rx pattern is the trio of callbacks that get subscribed to an Observable for receiving events.

    The Observer from the Rx pattern is the trio of callbacks that get subscribed to an Observable for receiving events.

    The events received must follow the Rx grammar, which is: onNext * (onComplete | onError)?

    That means an Observer can receive zero or multiple events, the stream ending either in one or zero onComplete or onError (just one, not both), and after onComplete or onError, a well behaved Observable implementation shouldn't send any more onNext events.

  6. sealed abstract class OverflowStrategy[+A] extends Serializable

    Permalink

    Represents the buffering overflowStrategy chosen for actions that need buffering, instructing the pipeline what to do when the buffer is full.

    Represents the buffering overflowStrategy chosen for actions that need buffering, instructing the pipeline what to do when the buffer is full.

    For the available policies, see:

    - Unbounded - Fail - BackPressure

    Used in BufferedSubscriber to implement buffering when concurrent actions are needed, such as in Channels or in Observable.merge.

  7. abstract class Pipe[I, +O] extends ObservableLike[O, [+α]Pipe[I, α]]

    Permalink

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

Value Members

  1. object Consumer extends Serializable

    Permalink

    The companion object of Consumer, defines consumer builders.

  2. object MulticastStrategy extends Serializable

    Permalink

    The MulticastStrategy enumerated.

  3. object Notification extends Serializable

    Permalink
  4. object Observable extends Serializable

    Permalink

    Observable builders.

  5. object Observer extends Serializable

    Permalink

  6. object OverflowStrategy extends Serializable

    Permalink
  7. object Pipe extends Serializable

    Permalink
  8. package exceptions

    Permalink
  9. package observables

    Permalink
  10. package observers

    Permalink
  11. package subjects

    Permalink

Ungrouped