Package de.dytanic.cloudnet.common.concurrent

Class CompletableTask<V>

java.lang.Object

de.dytanic.cloudnet.common.concurrent.CompletableTask<V>

All Implemented Interfaces:

ITask<V>, java.util.concurrent.Callable<V>, java.util.concurrent.Future<V>

Direct Known Subclasses:

CountingTask, NullCompletableTask

public class CompletableTask<V>
extends java.lang.Object
implements ITask<V>

Constructor Summary

Constructors

Constructor	Description
CompletableTask()

Method Summary

Modifier and Type	Method	Description
@NotNull ITask<V>	addListener(ITaskListener<V> listener)
V	call()
boolean	cancel(boolean b)
@NotNull ITask<V>	clearListeners()
void	complete(V value)
void	fail(java.lang.Throwable throwable)
V	get()
V	get(long l, @NotNull java.util.concurrent.TimeUnit timeUnit)
V	get(long time, java.util.concurrent.TimeUnit timeUnit, V def)
java.util.concurrent.Callable<V>	getCallable()
V	getDef(V def)
java.util.Collection<ITaskListener<V>>	getListeners()
boolean	isCancelled()
boolean	isDone()
static <I,O> ITask<O>	mapFrom(ITask<I> source, ThrowableFunction<I,O,java.lang.Throwable> mapper)
<T> ITask<T>	mapThrowable(ThrowableFunction<V,T,java.lang.Throwable> mapper)
static <V> CompletableTask<V>	supplyAsync(ThrowableSupplier<V,java.lang.Throwable> supplier)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface de.dytanic.cloudnet.common.concurrent.ITask

addListener, fireExceptionOnFailure, map, onCancelled, onComplete, onComplete, onFailure, onFailure

Constructor Detail

CompletableTask

public CompletableTask()

Method Detail

supplyAsync

public static <V> CompletableTask<V> supplyAsync(ThrowableSupplier<V,java.lang.Throwable> supplier)

mapFrom

public static <I,O> ITask<O> mapFrom(ITask<I> source,
                                           ThrowableFunction<I,O,java.lang.Throwable> mapper)

addListener

@NotNull
public @NotNull ITask<V> addListener(ITaskListener<V> listener)

Specified by:

addListener in interface ITask<V>

clearListeners

@NotNull
public @NotNull ITask<V> clearListeners()

Specified by:

clearListeners in interface ITask<V>

getListeners

public java.util.Collection<ITaskListener<V>> getListeners()

Specified by:

getListeners in interface ITask<V>

getCallable

public java.util.concurrent.Callable<V> getCallable()

Specified by:

getCallable in interface ITask<V>

getDef

public V getDef(V def)

Specified by:

getDef in interface ITask<V>

get

public V get(long time,
             java.util.concurrent.TimeUnit timeUnit,
             V def)

Specified by:

get in interface ITask<V>

fail

public void fail(java.lang.Throwable throwable)

call

public V call()

Specified by:

call in interface java.util.concurrent.Callable<V>

complete

public void complete(V value)

cancel

public boolean cancel(boolean b)

Specified by:

cancel in interface java.util.concurrent.Future<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<V>

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<V>

get

public V get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<V>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public V get(long l,
             @NotNull
             @NotNull java.util.concurrent.TimeUnit timeUnit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<V>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

mapThrowable

public <T> ITask<T> mapThrowable(ThrowableFunction<V,T,java.lang.Throwable> mapper)

Specified by:

mapThrowable in interface ITask<V>