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

CpsAsyncEmitAbsorber

cps.stream.CpsAsyncEmitAbsorber
See theCpsAsyncEmitAbsorber companion object
trait CpsAsyncEmitAbsorber[R]

This typeclass should be implemented for streams, which can be a target of asyncStream. i.e. if we want use generator of form

asyncStream[R] { out =>
   ...
   out.emit(value)
}

Then we should have an implementation of given CpsAsyncEmitAbsorber[R] in the current scope.

Attributes

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

Members list

Type members

Types

type Element

Attributes

Source
CpsAsyncEmitAbsorber.scala
type Monad[_]

Attributes

Source
CpsAsyncEmitAbsorber.scala

Value members

Abstract methods

def eval(f: Context => (CpsAsyncEmitter[Monad, Element]) => Monad[Unit]): R

Attributes

Source
CpsAsyncEmitAbsorber.scala
Generated with