object Pipe extends Serializable
- Source
- Pipe.scala
- Alphabetic
- By Inheritance
- Pipe
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
- def apply[A](strategy: MulticastStrategy[A]): Pipe[A, A]
Given a MulticastStrategy returns the corresponding Pipe.
- def async[A]: Pipe[A, A]
Subject recipe for building AsyncSubject instances.
- def behavior[A](initial: A): Pipe[A, A]
Subject recipe for building BehaviorSubject instances.
- def publish[A]: Pipe[A, A]
Subject recipe for building PublishSubject instances.
- def publishToOne[A]: Pipe[A, A]
Subject recipe for building PublishToOneSubject instances.
- def replay[A](initial: Seq[A]): Pipe[A, A]
Subject recipe for building unbounded ReplaySubject instances.
Subject recipe for building unbounded ReplaySubject instances.
- initial
is an initial sequence of elements that will be pushed to subscribers before any elements emitted by the source.
- def replay[A]: Pipe[A, A]
Subject recipe for building unbounded monix.reactive.subjects. instances.
- def replayLimited[A](capacity: Int, initial: Seq[A]): Pipe[A, A]
Subject recipe for building ReplaySubject instances with a maximum
capacity(after which old items start being dropped).Subject recipe for building ReplaySubject instances with a maximum
capacity(after which old items start being dropped).- capacity
indicates the minimum capacity of the underlying buffer, with the implementation being free to increase it.
- initial
is an initial sequence of elements that will be pushed to subscribers before any elements emitted by the source.
- def replayLimited[A](capacity: Int): Pipe[A, A]
Subject recipe for building ReplaySubject instances with a maximum
capacity(after which old items start being dropped).Subject recipe for building ReplaySubject instances with a maximum
capacity(after which old items start being dropped).- capacity
indicates the minimum capacity of the underlying buffer, with the implementation being free to increase it.
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.