root
API
Generated with
root/cps/cps.stream

cps.stream

package cps.stream

Members list

Type members

Classlikes

trait AsyncIterator[F[_], T]

Minimal mutable async stream.

Minimal mutable async stream.

Attributes

Companion
object
Source
AsyncIterator.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class AsyncListIterator[F, T]
Self type
object AsyncIterator

Attributes

Companion
trait
Source
AsyncIterator.scala
Supertypes
class Object
trait Matchable
class Any
Self type
class AsyncIteratorEmitAbsorber[F[_], C <: CpsMonadContext[F], T](using ec: ExecutionContext, auxAsyncMonad: Aux[F, C]) extends CpsAsyncEmitAbsorber4[AsyncIterator[F, T], F, C, T]

Attributes

Source
AsyncIterator.scala
Supertypes
trait CpsAsyncEmitAbsorber4[AsyncIterator[F, T], F, C, T]
class Object
trait Matchable
class Any
sealed trait AsyncList[F[_], +T]

Mininal async stream.

Mininal async stream.

Attributes

Companion
object
Source
AsyncList.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class Cons[F, T]
class Empty[F]
class Wait[F, T]
object AsyncList

Attributes

Companion
trait
Source
AsyncList.scala
Supertypes
class Object
trait Matchable
class Any
Self type
AsyncList.type
class AsyncListEmitAbsorber[F[_], C <: CpsMonadContext[F], T](using ec: ExecutionContext, auxMonad: Aux[F, C]) extends BaseUnfoldCpsAsyncEmitAbsorber[AsyncList[F, T], F, C, T]

Attributes

Source
AsyncList.scala
Supertypes
trait CpsAsyncEmitAbsorber4[AsyncList[F, T], F, C, T]
class Object
trait Matchable
class Any
Show all
class AsyncListIterator[F[_], T](l: AsyncList[F, T])(implicit evidence$1: CpsConcurrentMonad[F], x$2: ExecutionContext) extends AsyncIterator[F, T]

Attributes

Source
AsyncListIterator.scala
Supertypes
trait AsyncIterator[F, T]
class Object
trait Matchable
class Any
class AsyncStreamHelper[R, F[_], C <: CpsMonadContext[F], A](val a: Aux[R, F, C, A])

Attributes

Source
CpsAsyncEmitAbsorber.scala
Supertypes
class Object
trait Matchable
class Any
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
Supertypes
trait CpsAsyncEmitAbsorber4[R, F, C, T]
class Object
trait Matchable
class Any
Known subtypes
class AsyncListEmitAbsorber[F, C, T]
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

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
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]
object CpsAsyncEmitAbsorber

Attributes

Companion
trait
Source
CpsAsyncEmitAbsorber.scala
Supertypes
class Object
trait Matchable
class Any
Self type
trait CpsAsyncEmitAbsorber4[R, F[_], C <: CpsMonadContext[F], T](using val auxAsyncMonad: Aux[F, C]) extends CpsAsyncEmitAbsorber[R]

Attributes

Source
CpsAsyncEmitAbsorber.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class AsyncIteratorEmitAbsorber[F, C, T]
trait BaseUnfoldCpsAsyncEmitAbsorber[R, F, C, T]
class AsyncListEmitAbsorber[F, C, T]
trait CpsAsyncEmitter[F[_], E]

Emitter which should be a parameter of asyncStream expression.

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
Supertypes
class Object
trait Matchable
class Any
Known subtypes
object CpsAsyncStreamMacro

Attributes

Source
CpsAsyncEmitAbsorber.scala
Supertypes
class Object
trait Matchable
class Any
Self type
Generated with