object SingleAssignCancelable extends Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- SingleAssignCancelable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Value Members
- def apply(): SingleAssignCancelable
Builder for SingleAssignCancelable.
- def plusOne(guest: Cancelable): SingleAssignCancelable
Builder for SingleAssignCancelable that takes an extra reference, to be canceled on cancel() along with whatever underlying reference we have.
Builder for SingleAssignCancelable that takes an extra reference, to be canceled on cancel() along with whatever underlying reference we have.
val c = { val extra = Cancelable(() => println("extra canceled") SingleAssignmentCancelable.withExtra(extra) } c := Cancelable(() => println("main canceled")) // ... c.cancel() //=> extra canceled //=> main canceled
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.