Generated with

root/cps/cps.stream/CpsAsyncEmitter

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: class StepsObserver

Members list

Value members

Abstract methods

Attributes

Source: CpsAsyncEmitter.scala

Concrete methods

Attributes

Source: CpsAsyncEmitter.scala

In this article

Generated with