rstreams

Type Members

1. final class SingleAssignmentSubscription extends Subscription

   

   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

   

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