CpsAsyncEmitter

cps.stream.CpsAsyncEmitter
trait CpsAsyncEmitter[F[_], E]

Emitter which should be a parameter of asyncStream expression.

 asyncStream[AsyncList[F,Int]] { out =>
    for(i <- 1 to 10)
       out.emit(i)
 }

Here out have a CpsAsyncEmitter[AsyncList[F,Int],F,E] type.

Attributes

See also

[cps. asyncStream]

Source
CpsAsyncEmitter.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def emitAsync(v: E): F[Unit]

Attributes

Source
CpsAsyncEmitter.scala

Concrete methods

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

Attributes

Source
CpsAsyncEmitter.scala