Package

monix.execution

rstreams

Permalink

package rstreams

Visibility
  1. Public
  2. All

Type Members

  1. final class SingleAssignmentSubscription extends Subscription

    Permalink

    Represents a org.reactivestreams.Subscription that can be assigned only once to another subscription reference.

    Represents a org.reactivestreams.Subscription that can be assigned only once to another subscription reference.

    If the assignment happens after this subscription has been canceled, then on assignment the reference will get canceled too. If the assignment after request(n) has been called on this subscription, then request(n) will get called immediately on the assigned reference as well.

    Useful in case you need a thread-safe forward reference.

  2. trait Subscription extends org.reactivestreams.Subscription with Cancelable

    Permalink

    The Subscription represents a cross between the Monix Cancelable and org.reactivestreams.Subcription.

    The Subscription represents a cross between the Monix Cancelable and org.reactivestreams.Subcription.

    Represents a one-to-one lifecycle of a Subscriber subscribing to a Publisher and mirrors the Subscription interface from the Reactive Streams specification.

    It can be used only once by a single Subscriber. It is used for both signaling demand for data and for canceling demand (and allow resource cleanup).

Value Members

  1. object SingleAssignmentSubscription extends Serializable

    Permalink
  2. object Subscription extends Serializable

    Permalink

Ungrouped