BlockingIO2

izumi.functional.bio.BlockingIO2
See theBlockingIO2 companion object

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Type members

Inherited types

Attributes

Inherited from:
DivergenceHelper

Attributes

Inherited from:
PredefinedHelper

Value members

Abstract methods

def shiftBlocking[E, A](f: F[E, A]): F[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

def syncBlocking[A](effect: => A): F[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

def syncInterruptibleBlocking[A](effect: => A): F[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