object Blocker extends BlockerPlatform
- Source
- Blocker.scala
- Alphabetic
- By Inheritance
- Blocker
- BlockerPlatform
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final class OutstandingTasksAtShutdown extends IllegalStateException
Thrown if there are tasks queued in the thread pool at the time a
Blocker
is finalized.Thrown if there are tasks queued in the thread pool at the time a
Blocker
is finalized.- Definition Classes
- BlockerPlatform
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def apply[F[_]](implicit F: Sync[F]): Resource[F, Blocker]
Creates a blocker that is backed by a cached thread pool.
Creates a blocker that is backed by a cached thread pool.
- Definition Classes
- BlockerPlatform
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def fromExecutorService[F[_]](makeExecutorService: F[ExecutorService])(implicit F: Sync[F]): Resource[F, Blocker]
Creates a blocker backed by the
ExecutorService
returned by the supplied task.Creates a blocker backed by the
ExecutorService
returned by the supplied task. The executor service is shut down upon finalization of the returned resource.If there are pending tasks in the thread pool at time the returned
Blocker
is finalized, the finalizer fails with aBlocker.OutstandingTasksAtShutdown
exception.- Definition Classes
- BlockerPlatform
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def liftExecutionContext(ec: ExecutionContext): Blocker
Creates a blocker that delegates to the supplied execution context.
Creates a blocker that delegates to the supplied execution context.
This must not be used with general purpose contexts like
scala.concurrent.ExecutionContext.Implicits.global
.- Definition Classes
- Blocker → BlockerPlatform
- def liftExecutorService(es: ExecutorService): Blocker
Creates a blocker that delegates to the supplied executor service.
Creates a blocker that delegates to the supplied executor service.
- Definition Classes
- BlockerPlatform
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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 wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
This is the API documentation for the cats-effect library.
See the cats.effect package for a quick overview.
Links
Canonical documentation links:
Related Cats links (the core):