package rstreams
Package exposing utilities for working with the Reactive Streams specification.
- Alphabetic
- By Inheritance
- rstreams
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
sealed abstract
class
ReactivePullStrategy extends Product with Serializable
Describes a strategy of buffering data when converting a
Publisher
into other data types likemonix.tail.Iterant
.Describes a strategy of buffering data when converting a
Publisher
into other data types likemonix.tail.Iterant
.To override a strategy, provide it as an implicit:
implicit val pullStrategy: ReactivePullStrategy = ReactivePullStrategy.Batched(256) // The call will use strategy defined above Iterant[Task].fromReactivePublisher(publisher)
-
final
class
SingleAssignSubscription 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, thenrequest(n)
will get called immediately on the assigned reference as well.Useful in case you need a thread-safe forward reference.
-
trait
Subscription extends org.reactivestreams.Subscription with Cancelable
The
Subscription
represents a cross between the Monix Cancelable andorg.reactivestreams.Subcription
.The
Subscription
represents a cross between the Monix Cancelable andorg.reactivestreams.Subcription
.Represents a one-to-one lifecycle of a
Subscriber
subscribing to aPublisher
and mirrors theSubscription
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). -
type
SingleAssignmentSubscription = SingleAssignSubscription
DEPRECATED — renamed to SingleAssignSubscription.
DEPRECATED — renamed to SingleAssignSubscription.
- Annotations
- @deprecated
- Deprecated
(Since version 3.0.0) Renamed to SingleAssignSubscription
Value Members
- object ReactivePullStrategy extends Serializable
- object SingleAssignSubscription extends Serializable
- object Subscription extends Serializable
Deprecated Value Members
-
val
SingleAssignmentSubscription: SingleAssignSubscription.type
DEPRECATED — renamed to SingleAssignSubscription.
DEPRECATED — renamed to SingleAssignSubscription.
- Annotations
- @deprecated
- Deprecated
(Since version 3.0.0) Renamed to SingleAssignSubscription