Parallel2

izumi.functional.bio.Parallel2
trait Parallel2[F[_, _]] extends RootBifunctor[F]

Attributes

Graph
Supertypes
trait RootBifunctor[F]
trait Root
class Object
trait Matchable
class Any
Show all
Known subtypes
trait Concurrent2[F]
trait Async2[F]
class AsyncZio[R]
object AsyncZio
class TemporalZio[R]
object TemporalZio
trait WeakAsync2[F]
Show all

Members list

Type members

Inherited types

Attributes

Inherited from:
DivergenceHelper

Attributes

Inherited from:
PredefinedHelper

Value members

Abstract methods

def InnerF: Monad2[F]
def parTraverse[E, A, B](l: Iterable[A])(f: A => F[E, B]): F[E, List[B]]
def parTraverseN[E, A, B](maxConcurrent: Int)(l: Iterable[A])(f: A => F[E, B]): F[E, List[B]]
def parTraverseNCore[E, A, B](l: Iterable[A])(f: A => F[E, B]): F[E, List[B]]

parTraverseN with maxConcurrent set to the number of cores, or 2 when on single-core processor

parTraverseN with maxConcurrent set to the number of cores, or 2 when on single-core processor

Attributes

def zipWithPar[E, A, B, C](fa: F[E, A], fb: F[E, B])(f: (A, B) => C): F[E, C]

Returns an effect that executes both effects, in parallel, combining their results with the specified f function. If either side fails, then the other side will be interrupted.

Returns an effect that executes both effects, in parallel, combining their results with the specified f function. If either side fails, then the other side will be interrupted.

Attributes

Concrete methods

def parTraverseNCore_[E, A](l: Iterable[A])(f: A => F[E, Unit]): F[E, Unit]
def parTraverseN_[E, A](maxConcurrent: Int)(l: Iterable[A])(f: A => F[E, Unit]): F[E, Unit]
def parTraverse_[E, A](l: Iterable[A])(f: A => F[E, Unit]): F[E, Unit]
def zipPar[E, A, B](fa: F[E, A], fb: F[E, B]): F[E, (A, B)]

Returns an effect that executes both effects, in parallel, combining their results into a tuple. If either side fails, then the other side will be interrupted.

Returns an effect that executes both effects, in parallel, combining their results into a tuple. If either side fails, then the other side will be interrupted.

Attributes

def zipParLeft[E, A, B](fa: F[E, A], fb: F[E, B]): F[E, A]

Returns an effect that executes both effects, in parallel, the left effect result is returned. If either side fails, then the other side will be interrupted.

Returns an effect that executes both effects, in parallel, the left effect result is returned. If either side fails, then the other side will be interrupted.

Attributes

def zipParRight[E, A, B](fa: F[E, A], fb: F[E, B]): F[E, B]

Returns an effect that executes both effects, in parallel, the right effect result is returned. If either side fails, then the other side will be interrupted.

Returns an effect that executes both effects, in parallel, the right effect result is returned. If either side fails, then the other side will be interrupted.

Attributes