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

BaseUnfoldCpsAsyncEmitAbsorber

cps.stream.BaseUnfoldCpsAsyncEmitAbsorber
trait BaseUnfoldCpsAsyncEmitAbsorber[R, F[_], C <: CpsMonadContext[F], T](using val ec: ExecutionContext, val asyncMonad: CpsConcurrentMonad[F] { type Context = C; }) extends CpsAsyncEmitAbsorber4[R, F, C, T]

Attributes

Source
BaseUnfoldCpsAsyncEmitAbsorber.scala
Graph
Supertypes
trait CpsAsyncEmitAbsorber4[R, F, C, T]
class Object
trait Matchable
class Any
Known subtypes
class AsyncListEmitAbsorber[F, C, T]

Members list

Type members

Classlikes

case class Emitted(value: T, emitPromise: Promise[Unit]) extends SupplyEventRecord

Attributes

Source
BaseUnfoldCpsAsyncEmitAbsorber.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
case class Finished(result: Try[Unit]) extends SupplyEventRecord

Attributes

Source
BaseUnfoldCpsAsyncEmitAbsorber.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
case object SpawnEmitter extends SupplyEventRecord

Attributes

Source
BaseUnfoldCpsAsyncEmitAbsorber.scala
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
Self type
class State

Attributes

Source
BaseUnfoldCpsAsyncEmitAbsorber.scala
Supertypes
class Object
trait Matchable
class Any
class StepsObserver(state: State) extends CpsAsyncEmitter[F, T]

Attributes

Source
BaseUnfoldCpsAsyncEmitAbsorber.scala
Supertypes
trait CpsAsyncEmitter[F, T]
class Object
trait Matchable
class Any
sealed class SupplyEventRecord

Attributes

Source
BaseUnfoldCpsAsyncEmitAbsorber.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class Emitted
class Finished
object SpawnEmitter

Types

type OneThreadTaskCallback = Unit => Unit

Inherited types

override type Context = C

Attributes

Inherited from:
CpsAsyncEmitAbsorber4
Source
CpsAsyncEmitAbsorber.scala
override type Element = T

Attributes

Inherited from:
CpsAsyncEmitAbsorber4
Source
CpsAsyncEmitAbsorber.scala
override type Monad[X] = F[X]

Attributes

Inherited from:
CpsAsyncEmitAbsorber4
Source
CpsAsyncEmitAbsorber.scala

Value members

Abstract methods

def asSync(fs: F[R]): R
def unfold[S](s0: S)(f: S => F[Option[(T, S)]]): R

Concrete methods

def eval(f: C => (CpsAsyncEmitter[Monad, Element]) => F[Unit]): R
def evalAsync(f: C => (CpsAsyncEmitter[F, T]) => F[Unit]): F[R]
def evalAsyncInternal(f: (CpsAsyncEmitter[F, T]) => F[Unit]): R

Givens

Givens

given asyncMonad: CpsConcurrentMonad[F] { type Context = C; }
given ec: ExecutionContext

Inherited givens

given auxAsyncMonad: Aux[F, C]

Attributes

Inherited from:
CpsAsyncEmitAbsorber4
Source
CpsAsyncEmitAbsorber.scala
Generated with