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

AsyncListIterator

cps.stream.AsyncListIterator
class AsyncListIterator[F[_], T](l: AsyncList[F, T])(implicit evidence$1: CpsConcurrentMonad[F], x$2: ExecutionContext) extends AsyncIterator[F, T]

Attributes

Source
AsyncListIterator.scala
Graph
Supertypes
trait AsyncIterator[F, T]
class Object
trait Matchable
class Any

Members list

Type members

Classlikes

sealed trait State

Attributes

Source
AsyncListIterator.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class StateInit
class StateNext
case class StateInit(l: AsyncList[F, T]) extends State

Attributes

Source
AsyncListIterator.scala
Supertypes
trait Serializable
trait Product
trait Equals
trait State
class Object
trait Matchable
class Any
Show all
case class StateNext(cachedNext: Promise[Option[(T, AsyncList[F, T])]]) extends State

Attributes

Source
AsyncListIterator.scala
Supertypes
trait Serializable
trait Product
trait Equals
trait State
class Object
trait Matchable
class Any
Show all

Value members

Concrete methods

def next: F[Option[T]]

return the next element of stream in option or None if stream is finished.

return the next element of stream in option or None if stream is finished.

Attributes

Source
AsyncListIterator.scala

Inherited methods

def filter(p: T => Boolean): AsyncIterator[F, T]

filter accumulator by p, returning only those values, which as satisficy p.

filter accumulator by p, returning only those values, which as satisficy p.

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def filterAsync(p: T => F[Boolean]): AsyncIterator[F, T]

filter accumulator by p, returning only those values, which as satisficy p. Note, that p is applied sequentially

filter accumulator by p, returning only those values, which as satisficy p. Note, that p is applied sequentially

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def find(p: T => Boolean): F[Option[T]]

Find first value wich satisficy p

Find first value wich satisficy p

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def findAsync(p: T => F[Boolean]): F[Option[T]]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def flatMap[S](f: T => AsyncIterator[F, S]): AsyncIterator[F, S]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def flatMapAsync[S](f: T => F[AsyncIterator[F, S]]): AsyncIterator[F, S]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def flatMapTry[S](f: (Try[T]) => AsyncIterator[F, S]): AsyncIterator[F, S]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def flatMapTryAsync[S](f: (Try[T]) => F[AsyncIterator[F, S]]): AsyncIterator[F, S]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def fold[S](s0: S)(f: (S, T) => S): F[S]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def foldAsync[S](s0: S)(f: (S, T) => F[S]): F[S]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def inTry: AsyncIterator[F, Try[T]]

synonym for mapTry(identity)

synonym for mapTry(identity)

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def map[S](f: T => S): AsyncIterator[F, S]

return iterator with values mapped by f

return iterator with values mapped by f

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def mapAsync[S](f: T => F[S]): AsyncIterator[F, S]

map over async function. Substituted automatically when using await inside async block in map.

map over async function. Substituted automatically when using await inside async block in map.

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def mapTry[S](f: (Try[T]) => S): AsyncIterator[F, S]

map over Try[T], which allows to handle the cases, when next returns a failure. Be carefuel for situation, when failed next have no effect - in this case we will receive the infinite sequence of failuers.

map over Try[T], which allows to handle the cases, when next returns a failure. Be carefuel for situation, when failed next have no effect - in this case we will receive the infinite sequence of failuers.

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def mapTryAsync[S](f: (Try[T]) => F[S]): AsyncIterator[F, S]

async version of mapTry

async version of mapTry

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def scan[S](s0: S)(f: (S, T) => S): AsyncIterator[F, S]

Scan the value and output in the resulting iterator cummulative accumulated values. Note, that

Scan the value and output in the resulting iterator cummulative accumulated values. Note, that

  • f should be side effects free, since it can be reapplied in situation, when parallel threads tryng to read the next value
  • s0 and f(s,t) should not be nulls.

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def scanAsync[S](s0: S)(f: (S, T) => F[S]): AsyncIterator[F, S]

Scan the value and output in the resulting iterator cummulative accumulated values. Note, that

Scan the value and output in the resulting iterator cummulative accumulated values. Note, that

  • f should be side effects free, since it can be reapplied in situation, when parallel threads tryng to read the next value
  • s0 and f(s,t) should not be nulls.

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def take[CC[_]](n: Int)(using Factory[T, CC[T]]): F[CC[T]]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def takeAll[CC[_]](n: Int)(using Factory[T, CC[T]]): F[CC[T]]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def takeList(n: Int): F[List[T]]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def takeTo[B <: Growable[T]](buffer: B, n: Int): F[B]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala
def takeVector(n: Int): F[Vector[T]]

Attributes

Inherited from:
AsyncIterator
Source
AsyncIterator.scala

Concrete fields

var state: State

Attributes

Source
AsyncListIterator.scala
Generated with