object BufferCapacity extends Serializable
- Source
- BufferCapacity.scala
- Alphabetic
- By Inheritance
- BufferCapacity
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- final case class Bounded(capacity: Int) extends BufferCapacity with Product with Serializable
Describes a buffer with a limited capacity.
Describes a buffer with a limited capacity.
The overflow strategy depends on the implementation, the
capacityparameter describing just the size of the memory used.Also note that depending on the implementation this capacity can get rounded to a power of 2 for optimization purposes, so it's not necessarily a precise measurement of how many elements can be stored.
- final case class Unbounded(chunkSizeHint: Option[Int] = None) extends BufferCapacity with Product with Serializable
Describes an unbounded buffer that can use the entire memory available.
Describes an unbounded buffer that can use the entire memory available.
- chunkSizeHint
is an optimization hint — in case the underlying buffer is based on
Arraychunks, thechunkSizeHintspecifies the desired chunk size; this parameter is just a hint and implementations don't guarantee its usage
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.