root
API
Generated with
root/cps/cps.stream/AsyncIteratorEmitAbsorber

AsyncIteratorEmitAbsorber

cps.stream.AsyncIteratorEmitAbsorber
class AsyncIteratorEmitAbsorber[F[_], C <: CpsMonadContext[F], T](using ec: ExecutionContext, auxAsyncMonad: Aux[F, C]) extends CpsAsyncEmitAbsorber4[AsyncIterator[F, T], F, C, T]

Attributes

Source
AsyncIterator.scala
Graph
Supertypes
trait CpsAsyncEmitAbsorber4[AsyncIterator[F, T], F, C, T]
class Object
trait Matchable
class Any

Members list

Type members

Types

override type Context = C

Attributes

Source
AsyncIterator.scala
override type Element = T

Attributes

Source
AsyncIterator.scala

Inherited types

override type Monad[X] = F[X]

Attributes

Inherited from:
CpsAsyncEmitAbsorber4
Source
CpsAsyncEmitAbsorber.scala

Value members

Concrete methods

override def eval(f: C => CpsAsyncEmitter[Monad, Element] => F[Unit]): AsyncIterator[F, T]

Attributes

Definition Classes
Source
AsyncIterator.scala

Concrete fields

override val asyncMonad: Aux[Monad, Context]

Attributes

Source
AsyncIterator.scala
Generated with