TemporalZio

Companion object TemporalZio

class TemporalZio[R] extends AsyncZio[R] with Temporal2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Linear Supertypes

Temporal2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], TemporalInstances, AsyncZio[R], Async2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], IO2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Panic2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], PanicSyntax, Bracket2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Error2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], ErrorAccumulatingOps2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Monad2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], ApplicativeError2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Bifunctor2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Guarantee2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Applicative2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Functor2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Concurrent2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Parallel2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], RootBifunctor[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]], Root, PredefinedHelper, DivergenceHelper, AnyRef, Any

Known Subclasses

TemporalZio

Ordering

Alphabetic
By Inheritance

Inherited

TemporalZio
Temporal2
TemporalInstances
AsyncZio
Async2
IO2
Panic2
PanicSyntax
Bracket2
Error2
ErrorAccumulatingOps2
Monad2
ApplicativeError2
Bifunctor2
Guarantee2
Applicative2
Functor2
Concurrent2
Parallel2
RootBifunctor
Root
PredefinedHelper
DivergenceHelper
AnyRef
Any

Hide All
Show All

Visibility

Public
Protected

Instance Constructors

new TemporalZio()

Type Members

final type Canceler = ZIO[R, Nothing, Unit]
Definition Classes
Async2
type Divergence = Nondivergent
Definition Classes
DivergenceHelper
type IsPredefined = NotPredefined
Definition Classes
PredefinedHelper

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def *>[E, A, B](f: ZIO[R, E, A], next: => ZIO[R, E, B]): ZIO[R, E, B]
execute two operations in order, return result of second operation
execute two operations in order, return result of second operation
Definition Classes
AsyncZio → Monad2 → Applicative2
Annotations
@inline()
final def <*[E, A, B](f: ZIO[R, E, A], next: => ZIO[R, E, B]): ZIO[R, E, A]
execute two operations in order, same as *>, but return result of first operation
execute two operations in order, same as *>, but return result of first operation
Definition Classes
AsyncZio → Monad2 → Applicative2
Annotations
@inline()
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def InnerF: TemporalZio.this.type
Definition Classes
AsyncZio → Async2 → ApplicativeError2 → Bifunctor2 → Concurrent2 → Parallel2
Annotations
@inline()
def accumulateErrorsImpl[ColL[_], ColR[x] <: IterableOnce[x], E, E1, A, B, B1, AC](col: ColR[A])(effect: (A) => ZIO[R, E, B], onLeft: (E) => IterableOnce[E1], init: AC, onRight: (AC, B) => AC, end: (AC) => B1)(implicit buildL: Factory[E1, ColL[E1]]): ZIO[R, ColL[E1], B1]
Attributes
protected[this]
Definition Classes
IO2 → ErrorAccumulatingOps2
final def apply[A](effect: => A): ZIO[R, Throwable, A]
Definition Classes
IO2
Annotations
@inline()
final def as[E, A, B](r: ZIO[R, E, A])(v: => B): ZIO[R, E, B]
Definition Classes
AsyncZio → Functor2
Annotations
@inline()
final def asInstanceOf[T0]: T0
Definition Classes
Any
final def async[E, A](register: ((Either[E, A]) => Unit) => Unit): ZIO[Any, E, A]
Definition Classes
AsyncZio → Async2
Annotations
@inline()
final def asyncCancelable[E, A](register: ((Either[E, A]) => Unit) => Canceler): ZIO[R, E, A]
Definition Classes
AsyncZio → Async2
Annotations
@inline()
final def asyncF[E, A](register: ((Either[E, A]) => Unit) => ZIO[R, E, Unit]): ZIO[R, E, A]
Definition Classes
AsyncZio → Async2
Annotations
@inline()
final def attempt[E, A](r: ZIO[R, E, A]): ZIO[R, Nothing, Either[E, A]]
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def bimap[E, A, E2, B](r: ZIO[R, E, A])(f: (E) => E2, g: (A) => B): ZIO[R, E2, B]
Definition Classes
AsyncZio → Error2 → Bifunctor2
Annotations
@inline()
final def bracket[E, A, B](acquire: ZIO[R, E, A])(release: (A) => ZIO[R, Nothing, Unit])(use: (A) => ZIO[R, E, B]): ZIO[R, E, B]
Definition Classes
AsyncZio → Bracket2
Annotations
@inline()
final def bracketCase[E, A, B](acquire: ZIO[R, E, A])(release: (A, Exit[E, B]) => ZIO[R, Nothing, Unit])(use: (A) => ZIO[R, E, B]): ZIO[R, E, B]
Definition Classes
AsyncZio → Bracket2
Annotations
@inline()
final def bracketExcept[E, A, B](acquire: (RestoreInterruption2[[+β$8$, +γ$9$]ZIO[R, β$8$, γ$9$]]) => ZIO[R, E, A])(release: (A, Exit[E, B]) => ZIO[R, Nothing, Unit])(use: (A) => ZIO[R, E, B]): ZIO[R, E, B]
Like bracketCase, but acquire can contain marked interruptible regions as in uninterruptibleExcept
Like bracketCase, but acquire can contain marked interruptible regions as in uninterruptibleExcept
Definition Classes
AsyncZio → Panic2
Annotations
@inline()
final def bracketOnFailure[E, A, B](acquire: ZIO[R, E, A])(cleanupOnFailure: (A, Failure[E]) => ZIO[R, Nothing, Unit])(use: (A) => ZIO[R, E, B]): ZIO[R, E, B]
Run release action only on a failure – _any failure_, INCLUDING interruption.
Run release action only on a failure – _any failure_, INCLUDING interruption. Do not run release action if use finished successfully.
Definition Classes
Bracket2
final def catchAll[E, A, E2](r: ZIO[R, E, A])(f: (E) => ZIO[R, E2, A]): ZIO[R, E2, A]
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def catchSome[E, A, E1 >: E](r: ZIO[R, E, A])(f: PartialFunction[E, ZIO[R, E1, A]]): ZIO[R, E1, A]
Definition Classes
AsyncZio → Error2
Annotations
@inline()
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native()
def collect[E, A, B](l: Iterable[A])(f: (A) => ZIO[R, E, Option[B]]): ZIO[R, E, List[B]]
Definition Classes
Applicative2
final def collectFirst[E, A, B](l: Iterable[A])(f: (A) => ZIO[R, E, Option[B]]): ZIO[R, E, Option[B]]
Definition Classes
AsyncZio → Monad2
Annotations
@inline()
final def currentEC: ZIO[Any, Nothing, ExecutionContext]
Definition Classes
AsyncZio → Async2
Annotations
@inline()
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
final def fail[E](v: => E): ZIO[Any, E, Nothing]
Definition Classes
AsyncZio → ApplicativeError2
Annotations
@inline()
final def filter[E, A](l: Iterable[A])(f: (A) => ZIO[R, E, Boolean]): ZIO[R, E, List[A]]
Definition Classes
AsyncZio → Applicative2
Annotations
@inline()
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable])
final def find[E, A](l: Iterable[A])(f: (A) => ZIO[R, E, Boolean]): ZIO[R, E, Option[A]]
Definition Classes
AsyncZio → Monad2
Annotations
@inline()
final def flatMap[E, A, B](r: ZIO[R, E, A])(f0: (A) => ZIO[R, E, B]): ZIO[R, E, B]
Definition Classes
AsyncZio → Monad2
Annotations
@inline()
def flatSequence[E, A](l: Iterable[ZIO[R, E, Iterable[A]]]): ZIO[R, E, List[A]]
Definition Classes
Applicative2
def flatSequenceAccumErrors[ColR[x] <: IterableOnce[x], ColIn[x] <: IterableOnce[x], ColL[_], E, A](col: ColR[ZIO[R, ColL[E], ColIn[A]]])(implicit buildR: Factory[A, ColR[A]], buildL: Factory[E, ColL[E]], iterL: (ColL[E]) => IterableOnce[E]): ZIO[R, ColL[E], ColR[A]]
flatSequence with error accumulation
flatSequence with error accumulation
Definition Classes
ErrorAccumulatingOps2
def flatTraverse[E, A, B](l: Iterable[A])(f: (A) => ZIO[R, E, Iterable[B]]): ZIO[R, E, List[B]]
Definition Classes
Applicative2
def flatTraverseAccumErrors[ColR[x] <: IterableOnce[x], ColIn[x] <: IterableOnce[x], ColL[_], E, A, B](col: ColR[A])(f: (A) => ZIO[R, ColL[E], ColIn[B]])(implicit buildR: Factory[B, ColR[B]], buildL: Factory[E, ColL[E]], iterL: (ColL[E]) => IterableOnce[E]): ZIO[R, ColL[E], ColR[B]]
flatTraverse with error accumulation
flatTraverse with error accumulation
Definition Classes
ErrorAccumulatingOps2
final def flatten[E, A](r: ZIO[R, E, ZIO[R, E, A]]): ZIO[R, E, A]
Definition Classes
AsyncZio → Monad2
Annotations
@inline()
final def flip[E, A](r: ZIO[R, E, A]): ZIO[R, A, E]
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def foldLeft[E, A, AC](l: Iterable[A])(z: AC)(f: (AC, A) => ZIO[R, E, AC]): ZIO[R, E, AC]
Definition Classes
AsyncZio → Monad2
Annotations
@inline()
final def forever[E, A](r: ZIO[R, E, A]): ZIO[R, E, Nothing]
Definition Classes
Applicative2
Annotations
@inline()
final def fromEither[E, A](effect: => Either[E, A]): ZIO[Any, E, A]
Definition Classes
AsyncZio → IO2 → ApplicativeError2
Annotations
@inline()
final def fromFuture[A](mkFuture: (ExecutionContext) => Future[A]): ZIO[Any, Throwable, A]
Definition Classes
AsyncZio → Async2
Annotations
@inline()
final def fromFuture[A](mkFuture: => Future[A]): ZIO[R, Throwable, A]
Definition Classes
Async2
Annotations
@inline()
final def fromFutureJava[A](javaFuture: => CompletionStage[A]): ZIO[Any, Throwable, A]
Definition Classes
AsyncZio → Async2
Annotations
@inline()
final def fromOption[E, A](errorOnNone: => E)(effect: => Option[A]): ZIO[Any, E, A]
Definition Classes
AsyncZio → IO2 → ApplicativeError2
Annotations
@inline()
def fromOption[E, A](errorOnNone: => E, r: ZIO[R, E, Option[A]]): ZIO[R, E, A]
Extracts the optional value or fails with the errorOnNone error
Extracts the optional value or fails with the errorOnNone error
Definition Classes
Error2
final def fromOptionF[E, A](fallbackOnNone: => ZIO[R, E, A], r: ZIO[R, E, Option[A]]): ZIO[R, E, A]
Extracts the optional value, or executes the fallbackOnNone effect
Extracts the optional value, or executes the fallbackOnNone effect
Definition Classes
AsyncZio → Monad2
Annotations
@inline()
final def fromOptionOr[E, A](valueOnNone: => A, r: ZIO[R, E, Option[A]]): ZIO[R, E, A]
Extracts the optional value, or returns the given valueOnNone value
Extracts the optional value, or returns the given valueOnNone value
Definition Classes
AsyncZio → Functor2
Annotations
@inline()
final def fromTry[A](effect: => Try[A]): ZIO[Any, Throwable, A]
Definition Classes
AsyncZio → IO2 → ApplicativeError2
Annotations
@inline()
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native()
final def guarantee[E, A](f: ZIO[R, E, A], cleanup: ZIO[R, Nothing, Unit]): ZIO[R, E, A]
Definition Classes
AsyncZio → Bracket2 → Guarantee2
Annotations
@inline()
final def guaranteeCase[E, A](f: ZIO[R, E, A], cleanup: (Exit[E, A]) => ZIO[R, Nothing, Unit]): ZIO[R, E, A]
Definition Classes
AsyncZio → Bracket2
Annotations
@inline()
final def guaranteeExceptOnInterrupt[E, A](f: ZIO[R, E, A], cleanupOnNonInterruption: (Either[Termination, Either[Error[E], Success[A]]]) => ZIO[R, Nothing, Unit]): ZIO[R, E, A]
Run cleanup on both _success_ and _failure_, if the failure IS NOT an interruption.
Run cleanup on both _success_ and _failure_, if the failure IS NOT an interruption.
Definition Classes
Bracket2
final def guaranteeOnFailure[E, A](f: ZIO[R, E, A], cleanupOnFailure: (Failure[E]) => ZIO[R, Nothing, Unit]): ZIO[R, E, A]
Run cleanup only on a failure – _any failure_, INCLUDING interruption.
Run cleanup only on a failure – _any failure_, INCLUDING interruption. Do not run cleanup if use finished successfully.
Definition Classes
Bracket2
final def guaranteeOnInterrupt[E, A](f: ZIO[R, E, A], cleanupOnInterruption: (Interruption) => ZIO[R, Nothing, Unit]): ZIO[R, E, A]
Run cleanup only on interruption.
Run cleanup only on interruption. Do not run cleanup if use finished successfully.
Definition Classes
Bracket2
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native()
final def ifThenElse[E, E1, A](cond: ZIO[R, E, Boolean])(ifTrue: => ZIO[R, E1, A], ifFalse: => ZIO[R, E1, A])(implicit ev: <:<[E, E1]): ZIO[R, E1, A]
Definition Classes
Monad2
Annotations
@inline()
final def ifThenElse[E, A](cond: Boolean)(ifTrue: => ZIO[R, E, A], ifFalse: => ZIO[R, E, A]): ZIO[R, E, A]
Definition Classes
Applicative2
Annotations
@inline()
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def iterateUntil[E, A](r: ZIO[R, E, A])(p: (A) => Boolean): ZIO[R, E, A]
Execute an action repeatedly until its result satisfies the given predicate and return that result, discarding all others.
Execute an action repeatedly until its result satisfies the given predicate and return that result, discarding all others.
Definition Classes
AsyncZio → Monad2
Annotations
@inline()
def iterateUntilF[E, A](init: A)(f: (A) => ZIO[R, E, A])(p: (A) => Boolean): ZIO[R, E, A]
Apply an effectful function iteratively until its result satisfies the given predicate and return that result.
Apply an effectful function iteratively until its result satisfies the given predicate and return that result.
Definition Classes
Monad2
final def iterateWhile[E, A](r: ZIO[R, E, A])(p: (A) => Boolean): ZIO[R, E, A]
Execute an action repeatedly until its result fails to satisfy the given predicate and return that result, discarding all others.
Execute an action repeatedly until its result fails to satisfy the given predicate and return that result, discarding all others.
Definition Classes
AsyncZio → Monad2
Annotations
@inline()
def iterateWhileF[E, A](init: A)(f: (A) => ZIO[R, E, A])(p: (A) => Boolean): ZIO[R, E, A]
Apply an effectful function iteratively until its result fails to satisfy the given predicate and return that result.
Apply an effectful function iteratively until its result fails to satisfy the given predicate and return that result.
Definition Classes
Monad2
final def leftFlatMap[E, A, E2](r: ZIO[R, E, A])(f: (E) => ZIO[R, Nothing, E2]): ZIO[R, E2, A]
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def leftMap[E, A, E2](r: ZIO[R, E, A])(f: (E) => E2): ZIO[R, E2, A]
Definition Classes
AsyncZio → Bifunctor2
Annotations
@inline()
final def leftMap2[E, A, E2, E3](firstOp: ZIO[R, E, A], secondOp: => ZIO[R, E2, A])(f: (E, E2) => E3): ZIO[R, E3, A]
map errors from two operations into a new error if both fail
map errors from two operations into a new error if both fail
Definition Classes
AsyncZio → Error2 → ApplicativeError2
Annotations
@inline()
final def map[E, A, B](r: ZIO[R, E, A])(f: (A) => B): ZIO[R, E, B]
Definition Classes
AsyncZio → Monad2 → Functor2
Annotations
@inline()
final def map2[E, A, B, C](r1: ZIO[R, E, A], r2: => ZIO[R, E, B])(f: (A, B) => C): ZIO[R, E, C]
execute two operations in order, map their results
execute two operations in order, map their results
Definition Classes
AsyncZio → Monad2 → Applicative2
Annotations
@inline()
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def never: ZIO[Any, Nothing, Nothing]
Definition Classes
AsyncZio → Async2 → Concurrent2
Annotations
@inline()
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def onEC[E, A](ec: ExecutionContext)(f: ZIO[R, E, A]): ZIO[R, E, A]
Definition Classes
AsyncZio → Async2
Annotations
@inline()
final def orElse[E, A, E2](r: ZIO[R, E, A], f: => ZIO[R, E2, A]): ZIO[R, E2, A]
execute second operation only if the first one fails
execute second operation only if the first one fails
Definition Classes
AsyncZio → Error2 → ApplicativeError2
Annotations
@inline()
final def orTerminate[A](r: ZIO[R, Throwable, A]): ZIO[R, Nothing, A]
Definition Classes
Panic2
Annotations
@inline()
final def parTraverse[E, A, B](l: Iterable[A])(f: (A) => ZIO[R, E, B]): ZIO[R, E, List[B]]
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()
final def parTraverseN[E, A, B](maxConcurrent: Int)(l: Iterable[A])(f: (A) => ZIO[R, E, B]): ZIO[R, E, List[B]]
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()
final def parTraverseNCore[E, A, B](l: Iterable[A])(f: (A) => ZIO[R, E, B]): ZIO[R, 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
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()
final def parTraverseNCore_[E, A, B](l: Iterable[A])(f: (A) => ZIO[R, E, B]): ZIO[R, E, Unit]
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()
final def parTraverseN_[E, A, B](maxConcurrent: Int)(l: Iterable[A])(f: (A) => ZIO[R, E, B]): ZIO[R, E, Unit]
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()
final def parTraverse_[E, A, B](l: Iterable[A])(f: (A) => ZIO[R, E, B]): ZIO[R, E, Unit]
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()
def partition[E, A](l: Iterable[ZIO[R, E, A]]): ZIO[R, Nothing, (List[E], List[A])]
Definition Classes
Error2
Annotations
@nowarn()
final def pure[A](a: A): ZIO[Any, Nothing, A]
Definition Classes
AsyncZio → Applicative2
Annotations
@inline()
final def race[E, A](r1: ZIO[R, E, A], r2: ZIO[R, E, A]): ZIO[R, 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
Definition Classes
AsyncZio → Concurrent2
Annotations
@inline()
final def racePairUnsafe[E, A, B](r1: ZIO[R, E, A], r2: ZIO[R, E, B]): ZIO[R, E, Either[(Exit[E, A], Fiber2[[+β$2$, +γ$3$]ZIO[R, β$2$, γ$3$], E, B]), (Fiber2[[+β$4$, +γ$5$]ZIO[R, β$4$, γ$5$], 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.
Definition Classes
AsyncZio → Concurrent2
Annotations
@inline()
final def redeem[E, A, E2, B](r: ZIO[R, E, A])(err: (E) => ZIO[R, E2, B], succ: (A) => ZIO[R, E2, B]): ZIO[R, E2, B]
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def redeemPure[E, A, B](r: ZIO[R, E, A])(err: (E) => B, succ: (A) => B): ZIO[R, Nothing, B]
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def repeatUntil[E, A](action: ZIO[R, E, Option[A]])(tooManyAttemptsError: => E, sleep: FiniteDuration, maxAttempts: Int): ZIO[R, E, A]
Definition Classes
Temporal2
Annotations
@inline()
final def retryUntil[E, A](r: ZIO[R, E, A])(f: (E) => Boolean): ZIO[R, E, A]
Retries this effect until its error satisfies the specified predicate.
Retries this effect until its error satisfies the specified predicate.
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def retryUntilF[E, A](r: ZIO[R, E, A])(f: (E) => ZIO[R, Nothing, Boolean]): ZIO[R, E, A]
Retries this effect until its error satisfies the specified effectful predicate.
Retries this effect until its error satisfies the specified effectful predicate.
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def retryWhile[E, A](r: ZIO[R, E, A])(f: (E) => Boolean): ZIO[R, E, A]
Retries this effect while its error satisfies the specified predicate.
Retries this effect while its error satisfies the specified predicate.
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def retryWhileF[E, A](r: ZIO[R, E, A])(f: (E) => ZIO[R, Nothing, Boolean]): ZIO[R, E, A]
Retries this effect while its error satisfies the specified effectful predicate.
Retries this effect while its error satisfies the specified effectful predicate.
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def sandbox[E, A](r: ZIO[R, E, A]): ZIO[R, Failure[E], A]
Definition Classes
AsyncZio → Panic2
Annotations
@inline()
Note
Will return either Exit.Error or Exit.Termination in the error channel. Exit.Interruption cannot be sandboxed. Use guaranteeOnInterrupt for cleanups on interruptions.
final def sandboxExit[E, A](r: ZIO[R, E, A]): ZIO[R, Nothing, Exit[E, A]]
Definition Classes
Panic2
Annotations
@inline()
Note
Will return either Exit.Error or Exit.Termination. Exit.Interruption cannot be sandboxed. Use guaranteeOnInterrupt for cleanups on interruptions.
final def sendInterruptToSelf: ZIO[Any, Nothing, Unit]
Signal interruption to this fiber.
Signal interruption to this fiber.
This is _NOT_ the same as
```
F.halt(Exit.Interrupted(Trace.forUnknownError))
```
The code above exits with Exit.Interrupted failure *unconditionally*, whereas sendInterruptToSelf will not exit when in an uninterruptible region. Example:
```
F.uninterruptible {
  F.halt(Exit.Interrupted(Trace.forUnknownError)) *>
  F.sync(println("Hello!")) // interrupted above. Hello _not_ printed
}
```
But with sendInterruptToSelf:
```
F.uninterruptible {
  F.sendInterruptToSelf *>
  F.sync(println("Hello!")) // Hello IS printed.
} *> F.sync(println("Impossible")) // interrupted immediately after `uninterruptible` block ends. Impossible _not_ printed
```
Definition Classes
AsyncZio → Panic2
Annotations
@inline()
See also
https://github.com/zio/interop-cats/issues/503 - History of supporting this method in ZIO
https://github.com/zio/zio/issues/6911 - related issue
final def sequence[E, A](l: Iterable[ZIO[R, E, A]]): ZIO[R, E, List[A]]
Definition Classes
AsyncZio → Applicative2
Annotations
@inline()
def sequenceAccumErrors[ColR[x] <: IterableOnce[x], ColL[_], E, A](col: ColR[ZIO[R, ColL[E], A]])(implicit buildR: Factory[A, ColR[A]], buildL: Factory[E, ColL[E]], iterL: (ColL[E]) => IterableOnce[E]): ZIO[R, ColL[E], ColR[A]]
sequence with error accumulation
sequence with error accumulation
Definition Classes
ErrorAccumulatingOps2
def sequenceAccumErrorsNEList[ColR[x] <: IterableOnce[x], E, A](col: ColR[ZIO[R, E, A]])(implicit buildR: Factory[A, ColR[A]]): ZIO[R, NEList[E], ColR[A]]
sequence with error accumulation
sequence with error accumulation
Definition Classes
ErrorAccumulatingOps2
def sequenceAccumErrors_[ColR[x] <: IterableOnce[x], ColL[_], E, A](col: ColR[ZIO[R, ColL[E], A]])(implicit buildL: Factory[E, ColL[E]], iterL: (ColL[E]) => IterableOnce[E]): ZIO[R, ColL[E], Unit]
sequence_ with error accumulation
sequence_ with error accumulation
Definition Classes
ErrorAccumulatingOps2
final def sequence_[E](l: Iterable[ZIO[R, E, Unit]]): ZIO[R, E, Unit]
Definition Classes
AsyncZio → Applicative2
Annotations
@inline()
final def sleep(duration: Duration): ZIO[R, Nothing, Unit]
Definition Classes
TemporalZio → Temporal2
Annotations
@inline()
final def suspend[A](effect: => ZIO[R, Throwable, A]): ZIO[R, Throwable, A]
Capture a side-effectful block of code that can throw exceptions and returns another effect
Capture a side-effectful block of code that can throw exceptions and returns another effect
Definition Classes
AsyncZio → IO2
Annotations
@inline()
final def suspendSafe[E, A](effect: => ZIO[R, E, A]): ZIO[R, E, A]
Capture an _exception-safe_ side-effect that returns another effect
Capture an _exception-safe_ side-effect that returns another effect
Definition Classes
AsyncZio → IO2
Annotations
@inline()
final def sync[A](effect: => A): ZIO[Any, Nothing, A]
Capture an _exception-safe_ side-effect such as memory mutation or randomness
Capture an _exception-safe_ side-effect such as memory mutation or randomness
Definition Classes
AsyncZio → IO2
Annotations
@inline()
Example:
1. import izumi.functional.bio.F val exceptionSafeArrayAllocation: F[Nothing, Array[Byte]] = { F.sync(new Array(256)) }
Note
If you're not completely sure that a captured block can't throw, use syncThrowable
,
sync means synchronous, that is, a blocking CPU effect, as opposed to a non-blocking asynchronous effect or a long blocking I/O effect (izumi.functional.bio.BlockingIO2#syncBlocking)
final def syncThrowable[A](effect: => A): ZIO[Any, Throwable, A]
Capture a side-effectful block of code that can throw exceptions
Capture a side-effectful block of code that can throw exceptions
Definition Classes
AsyncZio → IO2
Annotations
@inline()
Note
sync means synchronous, that is, a blocking CPU effect, as opposed to a non-blocking asynchronous effect or a long blocking I/O effect (izumi.functional.bio.BlockingIO2#syncBlocking)
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def tailRecM[E, A, B](a: A)(f: (A) => ZIO[R, E, Either[A, B]]): ZIO[R, E, B]
Definition Classes
Monad2
final def tap[E, A](r: ZIO[R, E, A], f: (A) => ZIO[R, E, Unit]): ZIO[R, E, A]
Definition Classes
AsyncZio → Monad2
Annotations
@inline()
final def tapBoth[E, A, E1 >: E](r: ZIO[R, E, A])(err: (E) => ZIO[R, E1, Unit], succ: (A) => ZIO[R, E1, Unit]): ZIO[R, E1, A]
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def tapError[E, A, E1 >: E](r: ZIO[R, E, A])(f: (E) => ZIO[R, E1, Unit]): ZIO[R, E1, A]
Definition Classes
AsyncZio → Error2
Annotations
@inline()
final def terminate(v: => Throwable): ZIO[Any, Nothing, Nothing]
Definition Classes
AsyncZio → Panic2
Annotations
@inline()
final def timeout[E, A](duration: Duration)(r: ZIO[R, E, A]): ZIO[R, E, Option[A]]
Definition Classes
TemporalZio → Temporal2
Annotations
@inline()
final def timeoutFail[E, A](duration: Duration)(e: => E, r: ZIO[R, E, A]): ZIO[R, E, A]
Definition Classes
Temporal2
Annotations
@inline()
def toString(): String
Definition Classes
AnyRef → Any
final def traverse[E, A, B](l: Iterable[A])(f: (A) => ZIO[R, E, B]): ZIO[R, E, List[B]]
Definition Classes
AsyncZio → Applicative2
Annotations
@inline()
final def traverse[E, A, B](o: Option[A])(f: (A) => ZIO[R, E, B]): ZIO[R, E, Option[B]]
Definition Classes
Applicative2
Annotations
@inline()
def traverseAccumErrors[ColR[x] <: IterableOnce[x], ColL[_], E, A, B](col: ColR[A])(f: (A) => ZIO[R, ColL[E], B])(implicit buildR: Factory[B, ColR[B]], buildL: Factory[E, ColL[E]], iterL: (ColL[E]) => IterableOnce[E]): ZIO[R, ColL[E], ColR[B]]
traverse with error accumulation
traverse with error accumulation
Definition Classes
ErrorAccumulatingOps2
def traverseAccumErrors_[ColR[x] <: IterableOnce[x], ColL[_], E, A](col: ColR[A])(f: (A) => ZIO[R, ColL[E], Unit])(implicit buildL: Factory[E, ColL[E]], iterL: (ColL[E]) => IterableOnce[E]): ZIO[R, ColL[E], Unit]
traverse_ with error accumulation
traverse_ with error accumulation
Definition Classes
ErrorAccumulatingOps2
final def traverse_[E, A](l: Iterable[A])(f: (A) => ZIO[R, E, Unit]): ZIO[R, E, Unit]
Definition Classes
AsyncZio → Applicative2
Annotations
@inline()
final def uninterruptible[E, A](r: ZIO[R, E, A]): ZIO[R, E, A]
Definition Classes
AsyncZio → Panic2
Annotations
@inline()
final def uninterruptibleExcept[E, A](r: (RestoreInterruption2[[+β$6$, +γ$7$]ZIO[R, β$6$, γ$7$]]) => ZIO[R, E, A]): ZIO[R, E, A]
Designate the effect uninterruptible, with exception of regions in it that are specifically marked to restore previous interruptibility status using the provided RestoreInterruption function
Designate the effect uninterruptible, with exception of regions in it that are specifically marked to restore previous interruptibility status using the provided RestoreInterruption function
Definition Classes
AsyncZio → Panic2
Annotations
@inline()
Example:
1. F.uninterruptibleExcept { restoreInterruption => val workLoop = { importantWorkThatMustNotBeInterrupted() *> log.info("Taking a break for a second, you can interrupt me while I wait!") *> restoreInterruption.apply { F.sleep(1.second) .guaranteeOnInterrupt(_ => log.info("Got interrupted!")) } *> log.info("No interruptions, going back to work!") *> workLoop } workLoop }
Note
Interruptibility status will be restored to what it was in the outer region, so if the outer region was also uninterruptible, the provided RestoreInterruption will have no effect. e.g. the expression F.uninterruptible { F.uninterruptibleExcept { restore => restore(F.sleep(1.second)) } is fully uninterruptible throughout
final def unit: ZIO[Any, Nothing, Unit]
Definition Classes
AsyncZio → Applicative2
Annotations
@inline()
final def unless[E, E1](cond: ZIO[R, E, Boolean])(ifFalse: => ZIO[R, E1, Unit])(implicit ev: <:<[E, E1]): ZIO[R, E1, Unit]
Definition Classes
Monad2
Annotations
@inline()
final def unless[E](cond: Boolean)(ifFalse: => ZIO[R, E, Unit]): ZIO[R, E, Unit]
Definition Classes
Applicative2
Annotations
@inline()
final def void[E, A](r: ZIO[R, E, A]): ZIO[R, E, Unit]
Definition Classes
AsyncZio → Functor2
Annotations
@inline()
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()
final def when[E, E1](cond: ZIO[R, E, Boolean])(ifTrue: => ZIO[R, E1, Unit])(implicit ev: <:<[E, E1]): ZIO[R, E1, Unit]
Definition Classes
Monad2
Annotations
@inline()
final def when[E](cond: Boolean)(ifTrue: => ZIO[R, E, Unit]): ZIO[R, E, Unit]
Definition Classes
Applicative2
Annotations
@inline()
final def widen[E, A, A1](r: ZIO[R, E, A])(implicit ev: <:<[A, A1]): ZIO[R, E, A1]
Definition Classes
Functor2
Annotations
@inline()
final def widenBoth[E, A, E1, A1](r: ZIO[R, E, A])(implicit ev: <:<[E, E1], ev2: <:<[A, A1]): ZIO[R, E1, A1]
Definition Classes
Bifunctor2
Annotations
@inline()
final def widenError[E, A, E1](r: ZIO[R, E, A])(implicit ev: <:<[E, E1]): ZIO[R, E1, A]
Definition Classes
Bifunctor2
Annotations
@inline()
final def withFilter[E, A](r: ZIO[R, E, A])(predicate: (A) => Boolean)(implicit filter: WithFilter[E], pos: SourceFilePositionMaterializer): ZIO[R, E, A]
for-comprehensions sugar:
for-comprehensions sugar:
```
for {
  (1, 2) <- F.pure((2, 1))
} yield ()
```
Use widenError to for pattern matching with non-Throwable errors:
```
val f = for {
  (1, 2) <- F.pure((2, 1)).widenError[Option[Unit]]
} yield ()
// f: F[Option[Unit], Unit] = F.fail(Some(())
```
Definition Classes
Error2
Annotations
@inline()
final def yieldNow: ZIO[Any, Nothing, Unit]
Definition Classes
AsyncZio → Concurrent2
Annotations
@inline()
final def zipPar[E, A, B](fa: ZIO[R, E, A], fb: ZIO[R, E, B]): ZIO[R, E, (A, B)]
Returns an effect that executes both effects, in parallel, combining their results into a tuple.
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.
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()
final def zipParLeft[E, A, B](fa: ZIO[R, E, A], fb: ZIO[R, E, B]): ZIO[R, E, A]
Returns an effect that executes both effects, in parallel, the left effect result is returned.
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.
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()
final def zipParRight[E, A, B](fa: ZIO[R, E, A], fb: ZIO[R, E, B]): ZIO[R, E, B]
Returns an effect that executes both effects, in parallel, the right effect result is returned.
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.
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()
final def zipWithPar[E, A, B, C](fa: ZIO[R, E, A], fb: ZIO[R, E, B])(f: (A, B) => C): ZIO[R, E, C]
Returns an effect that executes both effects, in parallel, combining their results with the specified f function.
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.
Definition Classes
AsyncZio → Parallel2
Annotations
@inline()

Inherited from Temporal2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from TemporalInstances

Inherited from AsyncZio[R]

Packages

TemporalZio

Companion object TemporalZio

class TemporalZio[R] extends AsyncZio[R] with Temporal2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Instance Constructors

Type Members

Value Members

Inherited from Temporal2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from TemporalInstances

Inherited from AsyncZio[R]

Inherited from Async2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from IO2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Panic2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from PanicSyntax

Inherited from Bracket2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Error2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from ErrorAccumulatingOps2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Monad2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from ApplicativeError2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Bifunctor2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Guarantee2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Applicative2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Functor2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Concurrent2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Parallel2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from RootBifunctor[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Root

Inherited from PredefinedHelper

Inherited from DivergenceHelper

Inherited from AnyRef

Inherited from Any

Ungrouped

Packages

TemporalZio

Companion object TemporalZio

class TemporalZio[R] extends AsyncZio[R] with Temporal2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Instance Constructors

Type Members

Value Members

Inherited from Temporal2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from TemporalInstances

Inherited from AsyncZio[R]

Inherited from Async2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from IO2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Panic2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from PanicSyntax

Inherited from Bracket2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Error2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from ErrorAccumulatingOps2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Monad2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from ApplicativeError2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Bifunctor2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Guarantee2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Applicative2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Functor2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Concurrent2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Parallel2[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from RootBifunctor[[+β$0$, +γ$1$]ZIO[R, β$0$, γ$1$]]

Inherited from Root

Inherited from PredefinedHelper

Inherited from DivergenceHelper

Inherited from AnyRef

Inherited from Any

Ungrouped

TemporalZio