Monix3.0.0 < Back

Packages

package root
This is the API documentation for the Monix library.
Package Overview
monix.execution exposes lower level primitives for dealing with asynchronous execution:
- monix.execution.atomic exposes the Atomic types, as alternative to java.util.concurrent.atomic
- monix.execution.cancelables contains several useful Cancelable implementations
- monix.execution.schedulers contains several useful Scheduler implementations
- monix.execution.rstreams contains helpers for dealing with the Reactive Streams specification
- monix.execution.misc provides miscellaneous primitives useful for dealing with concurrency
- monix.execution.exceptions groups some exceptions thrown by the implementation
monix.catnap exposes pure abstractions built on top of the Cats-Effect type classes:
- monix.catnap.cancelables exposes pure counterparts to the cancelable data types described in monix.execution.cancelables
monix.eval is for dealing with evaluation of results, thus exposing Task and Coeval.
monix.reactive exposes the Observable pattern:
- monix.reactive.observables groups reusable Observable implementations
- monix.reactive.observers groups reusable Observer implementations
- monix.reactive.subjects exposes Subject and ConcurrentSubject, which are implementations of hot observables that function both as input and output
monix.tail exposes Iterant for purely functional pull based streaming:
- monix.tail.batches describes Batch and BatchCursor, the alternatives to Scala's Iterable and Iterator respectively that we are using within Iterant's encoding
You 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.
Definition Classes
root
package monix
Definition Classes
root
package execution
Definition Classes
monix
object FutureUtils extends FutureUtilsForPlatform
Utilities for Scala's standard concurrent.Future.
Utilities for Scala's standard concurrent.Future.
Definition Classes
execution
object extensions
Provides extension methods for Future.
Provides extension methods for Future.
Definition Classes
FutureUtils
FutureCompanionExtensions
FutureExtensions

c

monix.execution.FutureUtils.extensions

FutureExtensions

implicit final class FutureExtensions[A] extends AnyVal

Provides utility methods added on Scala's concurrent.Future

Source: FutureUtils.scala

Linear Supertypes

Ordering

Alphabetic
By Inheritance

Inherited

FutureExtensions
AnyVal
Any

Hide All
Show All

Visibility

Public
All

Instance Constructors

new FutureExtensions(source: Future[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 dematerialize[U](implicit ev: <:<[A, Try[U]], ec: ExecutionContext): Future[U]
FutureUtils.dematerialize exposed as an extension method.
def getClass(): Class[_ <: AnyVal]
Definition Classes
AnyVal → Any
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
def materialize(implicit ec: ExecutionContext): Future[Try[A]]
FutureUtils.materialize exposed as an extension method.
val source: Future[A]
def timeout(atMost: FiniteDuration)(implicit s: Scheduler): Future[A]
FutureUtils.timeout exposed as an extension method.
def timeoutTo[U >: A](atMost: FiniteDuration, fallback: => Future[U])(implicit s: Scheduler): Future[U]
FutureUtils.timeoutTo exposed as an extension method.
def toString(): String
Definition Classes
Any