implicit final class Extensions extends AnyVal with ExecuteExtensions
Ordering
- Alphabetic
- By Inheritance
Inherited
- Extensions
- ExecuteExtensions
- AnyVal
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
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 getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val source: Scheduler
- Definition Classes
- Extensions → ExecuteExtensions
- def toString(): String
- Definition Classes
- Any
Deprecated Value Members
- def currentTimeMillis(): Long
DEPRECATED — use clockRealTime(MILLISECONDS).
DEPRECATED — use clockRealTime(MILLISECONDS).
- Annotations
- @deprecated
- Deprecated
(Since version 3.0.0) Use clockRealTime(MILLISECONDS)
- def executeAsync(cb: Runnable): Unit
- Definition Classes
- ExecuteExtensions
- Annotations
- @deprecated
- Deprecated
(Since version 3.4.0) Use
executedirectly, since Scala 2.11 support has been dropped
- def executeAsyncBatch(cb: TrampolinedRunnable): Unit
- Definition Classes
- ExecuteExtensions
- Annotations
- @deprecated
- Deprecated
(Since version 3.4.0) Extension methods are now implemented on
Schedulerdirectly
- def executeTrampolined(cb: TrampolinedRunnable): Unit
- Definition Classes
- ExecuteExtensions
- Annotations
- @deprecated
- Deprecated
(Since version 3.4.0) Extension methods are now implemented on
Schedulerdirectly
- def scheduleAtFixedRate(initialDelay: FiniteDuration, period: FiniteDuration)(action: => Unit): Cancelable
- Annotations
- @deprecated
- Deprecated
(Since version 3.4.0) Extension methods are now implemented on
Schedulerdirectly
- def scheduleOnce(initialDelay: FiniteDuration)(action: => Unit): Cancelable
- Annotations
- @deprecated
- Deprecated
(Since version 3.4.0) Extension methods are now implemented on
Schedulerdirectly
- def scheduleWithFixedDelay(initialDelay: FiniteDuration, delay: FiniteDuration)(action: => Unit): Cancelable
- Annotations
- @deprecated
- Deprecated
(Since version 3.4.0) Extension methods are now implemented on
Schedulerdirectly
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.