final case class Bounded(capacity: Int) extends BufferCapacity with Product with Serializable
Describes a buffer with a limited capacity.
The overflow strategy depends on the implementation, the capacity
parameter 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.
- Source
- BufferCapacity.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- Bounded
- BufferCapacity
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
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.