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

StepsObserver

cps.stream.BaseUnfoldCpsAsyncEmitAbsorber.StepsObserver
class StepsObserver(state: State) extends CpsAsyncEmitter[F, T]

Attributes

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

Members list

Value members

Concrete methods

def emitAsync(v: T): F[Unit]
def finish(r: Try[Unit]): Unit

Inherited methods

transparent inline def emit(v: T)(using CpsMonadContext[F]): Unit

Attributes

Inherited from:
CpsAsyncEmitter
Source
CpsAsyncEmitter.scala
Generated with