object MulticastStrategy extends Serializable
- Alphabetic
- By Inheritance
- MulticastStrategy
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- case class Behavior[A](initial: A) extends MulticastStrategy[A] with Product with Serializable
The
Behaviorstrategy is for building multicast observables that emit the most recently emitted item by the source before the source starts being mirrored.The
Behaviorstrategy is for building multicast observables that emit the most recently emitted item by the source before the source starts being mirrored.Corresponds to Pipe.behavior.
- case class Replay[A](initial: Seq[A]) extends MulticastStrategy[A] with Product with Serializable
The
Replaystrategy is for building multicast observables that repeat all the generated items by the source, regardless of when the source is subscribed.The
Replaystrategy is for building multicast observables that repeat all the generated items by the source, regardless of when the source is subscribed.Corresponds to Pipe.replay.
- case class ReplayLimited[A](capacity: Int, initial: Seq[A]) extends MulticastStrategy[A] with Product with Serializable
The
ReplayLimitedstrategy is for building multicast observables that repeat the generated items by the source, but limited by the maximum size of the underlying buffer.The
ReplayLimitedstrategy is for building multicast observables that repeat the generated items by the source, but limited by the maximum size of the underlying buffer.When maximum size is reached, the underlying buffer starts dropping older events. Note that the size of the resulting buffer is not necessarily the given capacity, as the implementation may choose to increase it for optimisation purposes.
Corresponds to Pipe.replayLimited.
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 async[A]: MulticastStrategy[A]
The
Asyncstrategy is for building multicast observables that emit the last value (and only the last value) of the source and only after the source completes.The
Asyncstrategy is for building multicast observables that emit the last value (and only the last value) of the source and only after the source completes.Corresponds to Pipe.async.
- def behavior[A](initial: A): MulticastStrategy[A]
The
Behaviorstrategy is for building multicast observables that emit the most recently emitted item by the source before the source starts being mirrored.The
Behaviorstrategy is for building multicast observables that emit the most recently emitted item by the source before the source starts being mirrored.Corresponds to Pipe.behavior.
- def clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def publish[A]: MulticastStrategy[A]
The
Publishstrategy is for emitting to a subscriber only those items that are emitted by the source subsequent to the time of the subscription.The
Publishstrategy is for emitting to a subscriber only those items that are emitted by the source subsequent to the time of the subscription.Corresponds to Pipe.publish.
- def replay[A](initial: Seq[A]): MulticastStrategy[A]
The
Replaystrategy is for building multicast observables that repeat all the generated items by the source, regardless of when the source is subscribed.The
Replaystrategy is for building multicast observables that repeat all the generated items by the source, regardless of when the source is subscribed.Corresponds to Pipe.replay.
- def replay[A]: MulticastStrategy[A]
The
Replaystrategy is for building multicast observables that repeat all the generated items by the source, regardless of when the source is subscribed.The
Replaystrategy is for building multicast observables that repeat all the generated items by the source, regardless of when the source is subscribed.Corresponds to Pipe.replay.
- def replayLimited[A](capacity: Int, initial: Seq[A]): MulticastStrategy[A]
The
ReplayLimitedstrategy is for building multicast observables that repeat the generated items by the source, but limited by the maximum size of the underlying buffer.The
ReplayLimitedstrategy is for building multicast observables that repeat the generated items by the source, but limited by the maximum size of the underlying buffer.When maximum size is reached, the underlying buffer starts dropping older events. Note that the size of the resulting buffer is not necessarily the given capacity, as the implementation may choose to increase it for optimisation purposes.
Corresponds to Pipe.replayLimited.
- def replayLimited[A](capacity: Int): MulticastStrategy[A]
The
ReplayLimitedstrategy is for building multicast observables that repeat the generated items by the source, but limited by the maximum size of the underlying buffer.The
ReplayLimitedstrategy is for building multicast observables that repeat the generated items by the source, but limited by the maximum size of the underlying buffer.When maximum size is reached, the underlying buffer starts dropping older events. Note that the size of the resulting buffer is not necessarily the given capacity, as the implementation may choose to increase it for optimisation purposes.
Corresponds to Pipe.replayLimited.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- object Async extends MulticastStrategy[Nothing] with Product with Serializable
The
Asyncstrategy is for building multicast observables that emit the last value (and only the last value) of the source and only after the source completes.The
Asyncstrategy is for building multicast observables that emit the last value (and only the last value) of the source and only after the source completes.Corresponds to Pipe.async.
- object Publish extends MulticastStrategy[Nothing] with Product with Serializable
The
Publishstrategy is for emitting to a subscriber only those items that are emitted by the source subsequent to the time of the subscription.The
Publishstrategy is for emitting to a subscriber only those items that are emitted by the source subsequent to the time of the subscription.Corresponds to Pipe.publish.
This is the API documentation for the Monix library.
Package Overview
monix.execution exposes lower level primitives for dealing with asynchronous execution:
Atomictypes, as alternative tojava.util.concurrent.atomicmonix.catnap exposes pure abstractions built on top of the Cats-Effect type classes:
monix.eval is for dealing with evaluation of results, thus exposing Task and Coeval.
monix.reactive exposes the
Observablepattern:Observableimplementationsmonix.tail exposes Iterant for purely functional pull based streaming:
BatchandBatchCursor, the alternatives to Scala'sIterableandIteratorrespectively that we are using within Iterant's encodingYou can control evaluation with type you choose - be it Task, Coeval, cats.effect.IO or your own as long as you provide correct cats-effect or cats typeclass instance.