Uses of Interface
io.zeebe.util.sched.future.ActorFuture

Packages that use ActorFuture

Package	Description
io.zeebe.util.sched
io.zeebe.util.sched.future
io.zeebe.util.sched.testing

Uses of ActorFuture in io.zeebe.util.sched

Methods in io.zeebe.util.sched that return ActorFuture

Modifier and Type	Method and Description
<T> ActorFuture<T>	ActorControl.call(Callable<T> callable) Callables actions are called while the actor is in the following actor lifecycle phases: ActorTask.ActorLifecyclePhase.STARTED
ActorFuture<Void>	ActorControl.call(Runnable action) Callables actions are called while the actor is in the following actor lifecycle phases: ActorTask.ActorLifecyclePhase.STARTED
ActorFuture<Void>	ActorControl.close()
ActorFuture<Void>	ActorTask.onTaskScheduled(ActorExecutor actorExecutor, ActorThreadGroup actorThreadGroup, TaskMetrics taskMetrics) called when the task is initially scheduled.
ActorFuture	ActorJob.setCallable(Callable<?> callable)
ActorFuture<Void>	ActorScheduler.submitActor(Actor actor) Submits an non-blocking, CPU-bound actor.
ActorFuture<Void>	ActorScheduler.submitActor(Actor actor, boolean collectTaskMetrics) Submits an non-blocking, CPU-bound actor.
ActorFuture<Void>	ActorScheduler.submitActor(Actor actor, boolean collectTaskMetrics, int schedulingHints) Submits an actor providing hints to the scheduler about how to best schedule the actor.
ActorFuture<Void>	ActorExecutor.submitCpuBound(ActorTask task, boolean collectTaskMetrics) Initially submit a non-blocking actor to be managed by this schedueler.
ActorFuture<Void>	ActorExecutor.submitIoBoundTask(ActorTask task, boolean collectTaskMetrics)

Methods in io.zeebe.util.sched with parameters of type ActorFuture

Modifier and Type	Method and Description
void	AsyncContext.async(ActorFuture<?> future) Use with care
<T> void	ActorControl.runOnCompletion(ActorFuture<T> future, java.util.function.BiConsumer<T,Throwable> callback) Invoke the callback when the given future is completed (successfully or exceptionally).
<T> void	ActorControl.runOnCompletionBlockingCurrentPhase(ActorFuture<T> future, java.util.function.BiConsumer<T,Throwable> callback) Invoke the callback when the given future is completed (successfully or exceptionally).
void	ActorJob.setResultFuture(ActorFuture resultFuture)

Method parameters in io.zeebe.util.sched with type arguments of type ActorFuture

Modifier and Type	Method and Description
<T> void	ActorControl.runOnCompletion(Collection<ActorFuture<T>> futures, java.util.function.Consumer<Throwable> callback) Invoke the callback when the given futures are completed (successfully or exceptionally).
<T> void	ActorControl.runOnFirstCompletion(Collection<ActorFuture<T>> futures, java.util.function.BiConsumer<T,Throwable> callback) Invoke the callback when the first future is completed successfully, or when all futures are completed exceptionally.
<T> void	ActorControl.runOnFirstCompletion(Collection<ActorFuture<T>> futures, java.util.function.BiConsumer<T,Throwable> callback, java.util.function.Consumer<T> closer) Invoke the callback when the first future is completed successfully, or when all futures are completed exceptionally.

Constructors in io.zeebe.util.sched with parameters of type ActorFuture

Constructor and Description
ActorFutureSubscription(ActorFuture<?> future, ActorJob callbackJob, int phaseMask)

Uses of ActorFuture in io.zeebe.util.sched.future

Classes in io.zeebe.util.sched.future that implement ActorFuture

Modifier and Type	Class and Description
class	CompletableActorFuture<V> Completable future implementation that is garbage free and reusable

Constructors in io.zeebe.util.sched.future with parameters of type ActorFuture

Constructor and Description
FutureContinuationRunnable(ActorFuture<T> future, java.util.function.BiConsumer<T,Throwable> consumer)

Uses of ActorFuture in io.zeebe.util.sched.testing

Methods in io.zeebe.util.sched.testing that return ActorFuture

Modifier and Type	Method and Description
<T> ActorFuture<T>	ControlledActorSchedulerRule.call(Callable<T> callable)
ActorFuture<Void>	ControlledActorSchedulerRule.submitActor(Actor actor)
ActorFuture<Void>	ActorSchedulerRule.submitActor(Actor actor)
ActorFuture<Void>	ActorSchedulerRule.submitActor(Actor actor, boolean useCountersManager)