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

AsyncIterator

cps.stream.AsyncIterator
See theAsyncIterator companion trait
object AsyncIterator

Attributes

Companion
trait
Source
AsyncIterator.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def empty[F[_] : CpsConcurrentMonad, T]: AsyncIterator[F, T]

Attributes

Source
AsyncIterator.scala
def error[F[_] : CpsConcurrentMonad, T](e: Throwable): AsyncIterator[F, T]

Attributes

Source
AsyncIterator.scala
def one[F[_] : CpsConcurrentMonad, T](value: T): AsyncIterator[F, T]

Attributes

Source
AsyncIterator.scala
def unfold[S, F[_] : CpsConcurrentMonad, T](s0: S)(f: S => F[Option[(T, S)]])(implicit evidence$1: CpsConcurrentMonad[F], ExecutionContext): AsyncIterator[F, T]

Attributes

Source
AsyncIterator.scala

Givens

Givens

given absorber[F[_], C <: CpsMonadContext[F], T](using ExecutionContext, Aux[F, C]): CpsAsyncEmitAbsorber4[AsyncIterator[F, T], F, C, T]

Attributes

Source
AsyncIterator.scala
given given_CpsTryMonad_AsyncIterator_CpsTryMonadInstanceContext_AsyncIterator[F[_] : CpsConcurrentMonad]: given_CpsTryMonad_AsyncIterator_CpsTryMonadInstanceContext_AsyncIterator[F]

Attributes

Source
AsyncIterator.scala
Generated with