implicit final class Extensions[A] extends AnyVal
- Alphabetic
- By Inheritance
- Extensions
- AnyVal
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Extensions(target: Subscriber[A])
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- Any
- final def ##: Int
- Definition Classes
- Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def contramap[B](f: (B) => A): Subscriber[B]
Given a contravariant mapping function, transform the source Subscriber by transforming the input.
- def feed(subscription: BooleanCancelable, iterator: Iterator[A]): Future[Ack]
Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.- subscription
is a BooleanCancelable that will be queried for its cancellation status, but only on asynchronous boundaries, and when it is seen as being
isCanceled
, streaming is stopped.- iterator
is the iterator of items to push downstream
- def feed(iterator: Iterator[A]): Future[Ack]
Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.- iterator
is the iterator of items to push downstream
- def feed(subscription: BooleanCancelable, iterable: Iterable[A]): Future[Ack]
Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.- subscription
is a BooleanCancelable that will be queried for its cancellation status, but only on asynchronous boundaries, and when it is seen as being
isCanceled
, streaming is stopped.- iterable
is the collection of items to push downstream
- def feed(iterable: Iterable[A]): Future[Ack]
Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.- iterable
is the collection of items to push downstream
- def getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def onNextAll(xs: Iterable[A]): Future[Ack]
Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.Feeds the source Subscriber with elements from the given collection, respecting the contract and returning a
Future[Ack]
with the last acknowledgement given after the last emitted element.- xs
the traversable object containing the elements to feed into our subscriber
- val target: Subscriber[A]
- def toReactive(requestCount: Int): org.reactivestreams.Subscriber[A]
Transforms the source Subscriber into a
org.reactivestreams.Subscriber
instance as defined by the Reactive Streams specification.Transforms the source Subscriber into a
org.reactivestreams.Subscriber
instance as defined by the Reactive Streams specification.- requestCount
a strictly positive number, representing the size of the buffer used and the number of elements requested on each cycle when communicating demand, compliant with the reactive streams specification
- def toReactive: org.reactivestreams.Subscriber[A]
Transforms the source Subscriber into a
org.reactivestreams.Subscriber
instance as defined by the Reactive Streams specification. - def toString(): String
- Definition Classes
- Any
This is the API documentation for the Monix library.
Package Overview
monix.execution exposes lower level primitives for dealing with asynchronous execution:
Atomic
types, as alternative tojava.util.concurrent.atomic
monix.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
Observable
pattern:Observable
implementationsmonix.tail exposes Iterant for purely functional pull based streaming:
Batch
andBatchCursor
, the alternatives to Scala'sIterable
andIterator
respectively 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.