Represents a possibly asynchronous unit of work, called "Task".

A Task is a function that takes an instance of Complete and returns nothing.

Complete is a handler that needs to be actively called to complete the Task.

Callable<T> worker = ...;
Future<T> result = Future.run(complete -> complete.with(Try.of(worker::call)));

Nested and Inner Type Summary

Modifier and Type	Class and Description
public static interface	Task.Complete< result type T> Completes a task.

Method Summary

Modifier and Type	Method and Description
public void	run(Task.Complete<T> a function that completes this task complete) Runs the task.

run back to summary

run	back to summary
public void run(Task.Complete<T> complete) throws Throwable Runs the task. Non-fatal errors are catched by a `Future`. Parameters complete:Task.Complete<T> a function that completes this task Exceptions Throwable: if an error occurs

public void run(Task.Complete<T> complete) throws Throwable

Runs the task. Non-fatal errors are catched by a Future.

Parameters

Exceptions

io.vavr.concurrent back to summary

Annotations

Type Parameters

Completes a task.

Modifier and Type	Method and Description
public boolean	Returns: `true`, if the task could be completed, otherwise `false`. Successive calls will result in `false`. with(Try<? extends T> the computation result value) A function that takes a `Try` (success or failure) and returns the state of completion.

with back to summary

with	back to summary
public boolean with(Try<? extends T> value) A function that takes a `Try` (success or failure) and returns the state of completion. Parameters value:Try<? extends T> the computation result Returns:boolean `true`, if the task could be completed, otherwise `false`. Successive calls will result in `false`.

public boolean with(Try<? extends T> value)

A function that takes a Try (success or failure) and returns the state of completion.

Parameters

Returns:boolean

true, if the task could be completed, otherwise false. Successive calls will result in false.