- final class AsyncScheduler extends ReferenceScheduler with BatchingScheduler
AsyncSchedulerschedules tasks to happen in the future with the given
ScheduledExecutorServiceand the tasks themselves are executed on the given
- trait BatchingScheduler extends Scheduler
Adds trampoline execution capabilities to schedulers, when inherited.
- final class CanBlock extends AnyRef
- @implicitNotFound("For blocking operations on the JVM, there should be an implicit " +
"available by default, or import monix.execution.schedulers.CanBlock.permit.")
- abstract class ExecutorScheduler extends SchedulerService with ReferenceScheduler with BatchingScheduler
- trait ReferenceScheduler extends Scheduler
Helper for building a Scheduler.
- trait SchedulerService extends Scheduler
A Scheduler type that provides methods for managing termination.
- final class ShiftedRunnable extends Runnable
Runnable that defers the execution of the given reference with an
- final case class StartAsyncBatchRunnable(start: TrampolinedRunnable, s: Scheduler) extends Runnable with Serializable with Product
Forces a real asynchronous boundary before executing the given TrampolinedRunnable.
is the TrampolinedRunnable instance that will get executed and that is supposed to trigger the execution of other trampolined runnables
is the scheduler that gets used for execution.
- final class TestScheduler extends ReferenceScheduler with BatchingScheduler
Scheduler and a provider of
cats.effect.Timerinstances, that can simulate async boundaries and time passage, useful for testing purposes.
- final class TracingRunnable extends Runnable
Runnableinto one that restores the given Local.Context upon execution of
- final class TracingScheduler extends Base
- final class TracingSchedulerService extends Base with SchedulerService
- final class TrampolineExecutionContext extends ExecutionContextExecutor
scala.concurrentExecutionContextimplementation that executes runnables immediately, on the current thread, by means of a trampoline implementation.
- final class TrampolineScheduler extends Scheduler
A Scheduler implementation that executes runnables immediately, on the current thread, by means of a trampoline implementation.
- trait TrampolinedRunnable extends Runnable
A marker for callbacks that can be batched and executed locally (on the current thread) by means of a trampoline (if the execution context / scheduler allows it).
- object AsyncScheduler extends Serializable
- object CanBlock
- object ExecutorScheduler extends Serializable
- object ReferenceScheduler extends Serializable
- object SchedulerService extends Serializable
- object TestScheduler extends Serializable
- object TracingScheduler extends Serializable
- object TracingSchedulerService extends Serializable
- object TrampolineExecutionContext
- object TrampolineScheduler extends Serializable