object Pipe extends Serializable
- Source
- Pipe.scala
- Alphabetic
- By Inheritance
- Pipe
- Serializable
- 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.eval is for dealing with evaluation of results, thus exposing Task and Coeval.
monix.reactive exposes the
Observablepattern:Observableimplementationsmonix.types implements type-class shims, to be translated to type-classes provided by libraries such as Cats or Scalaz.
monix.cats is the optional integration with the Cats library, providing translations for the types described in
monix.types.monix.scalaz is the optional integration with the Scalaz library, providing translations for the types described in
monix.types.