microsite
API
Generated with
microsite/izumi/izumi.functional/izumi.functional.bio/Concurrent2

Concurrent2

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

Attributes

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

Members list

Type members

Inherited types

type Divergence = Nondivergent

Attributes

Inherited from:
DivergenceHelper
type IsPredefined = NotPredefined

Attributes

Inherited from:
PredefinedHelper

Value members

Abstract methods

override def InnerF: Panic2[F]

Attributes

Definition Classes
def never: F[Nothing, Nothing]
def race[E, A](r1: F[E, A], r2: F[E, A]): F[E, A]

Race two actions, the winner is the first action to TERMINATE, whether by success or failure

Race two actions, the winner is the first action to TERMINATE, whether by success or failure

Attributes

def racePairUnsafe[E, A, B](fa: F[E, A], fb: F[E, B]): F[E, Either[(Exit[E, A], Fiber2[F, E, B]), (Fiber2[F, E, A], Exit[E, B])]]

Race two actions, the winner is the first action to TERMINATE, whether by success or failure

Race two actions, the winner is the first action to TERMINATE, whether by success or failure

Unlike race, the loser is not interrupted after the winner has terminated - whether by success or failure.

Attributes

def yieldNow: F[Nothing, Unit]

Inherited methods

def parTraverseAccumErrors[ColL[_], E, A, B](col: Iterable[A])(f: A => F[ColL[E], B])(implicit buildL: Factory[E, ColL[E]], iterL: ColL[E] => IterableOnce[E]): F[ColL[E], List[B]]

Attributes

Inherited from:
ParallelErrorAccumulatingOps2
def parTraverseAccumErrors_[ColL[_], E, A](col: Iterable[A])(f: A => F[ColL[E], Unit])(implicit buildL: Factory[E, ColL[E]], iterL: ColL[E] => IterableOnce[E]): F[ColL[E], Unit]

Attributes

Inherited from:
ParallelErrorAccumulatingOps2
def parTraverseNCore_[E, A](l: Iterable[A])(f: A => F[E, Unit]): F[E, Unit]

Attributes

Inherited from:
Parallel2
def parTraverseN_[E, A](maxConcurrent: Int)(l: Iterable[A])(f: A => F[E, Unit]): F[E, Unit]

Attributes

Inherited from:
Parallel2
def parTraverse_[E, A](l: Iterable[A])(f: A => F[E, Unit]): F[E, Unit]

Attributes

Inherited from:
Parallel2
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

Inherited from:
Parallel2
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

Inherited from:
Parallel2
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

Inherited from:
Parallel2

Inherited and Abstract methods

def parTraverse[E, A, B](l: Iterable[A])(f: A => F[E, B]): F[E, List[B]]

Attributes

Inherited from:
Parallel2
def parTraverseN[E, A, B](maxConcurrent: Int)(l: Iterable[A])(f: A => F[E, B]): F[E, List[B]]

Attributes

Inherited from:
Parallel2
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

Inherited from:
Parallel2
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

Inherited from:
Parallel2
Generated with