BlockingZio

izumi.functional.bio.BlockingIOInstances.BlockingZio
See theBlockingZio companion object
open class BlockingZio[R] extends BlockingIO2[[_, _] =>> ZIO[R, _$14, _$15]]

Attributes

Companion
object
Graph
Supertypes
trait BlockingIO2[[_, _] =>> ZIO[R, _$14, _$15]]
class Object
trait Matchable
class Any
Show all
Known subtypes
object BlockingZio

Members list

Type members

Inherited types

Attributes

Inherited from:
DivergenceHelper

Attributes

Inherited from:
PredefinedHelper

Value members

Concrete methods

override def shiftBlocking[E, A](f: ZIO[R, E, A]): ZIO[R, E, A]

Execute a blocking action on a Blocking thread pool; current task will be safely parked until the blocking task finishes *

Execute a blocking action on a Blocking thread pool; current task will be safely parked until the blocking task finishes *

Attributes

Definition Classes
override def syncBlocking[A](effect: => A): ZIO[Any, Throwable, A]

Execute a blocking impure effect on a Blocking thread pool; current task will be safely parked until the blocking task finishes *

Execute a blocking impure effect on a Blocking thread pool; current task will be safely parked until the blocking task finishes *

Attributes

Definition Classes
override def syncInterruptibleBlocking[A](effect: => A): ZIO[Any, Throwable, A]

Execute a blocking impure effect on a Blocking thread pool; current task will be safely parked until the blocking task finishes

Execute a blocking impure effect on a Blocking thread pool; current task will be safely parked until the blocking task finishes

If canceled, the task MAY be killed via java.lang.Thread#interrupt. There is no guarantee that this method may promptly, or ever, interrupt the enclosed task, and it may be legally implemented as an alias to syncBlocking

THIS IS USUALLY UNSAFE unless calling well-written libraries that specifically handle java.lang.InterruptedException

Attributes

Definition Classes