Package de.dytanic.cloudnet.common.concurrent

Interface ITask<V>

All Superinterfaces:

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

All Known Subinterfaces:

IScheduledTask<V>

All Known Implementing Classes:

CompletableTask, CompletedTask, CountingTask, DefaultScheduledTask, ListenableTask, NullCompletableTask

public interface ITask<V>
extends java.util.concurrent.Future<V>, java.util.concurrent.Callable<V>

Method Summary

Modifier and Type	Method	Description
@NotNull ITask<V>	addListener(ITaskListener<V> listener)
default @NotNull ITask<V>	addListener(ITaskListener<V>... listeners)
@NotNull ITask<V>	clearListeners()
default ITask<V>	fireExceptionOnFailure()
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()
default <T> ITask<T>	map(@Nullable java.util.function.Function<V,T> mapper)
<T> ITask<T>	mapThrowable(@Nullable ThrowableFunction<V,T,java.lang.Throwable> mapper)
default @NotNull ITask<V>	onCancelled(java.util.function.Consumer<ITask<V>> consumer)
default @NotNull ITask<V>	onComplete(java.util.function.BiConsumer<ITask<V>,V> consumer)
default @NotNull ITask<V>	onComplete(java.util.function.Consumer<V> consumer)
default @NotNull ITask<V>	onFailure(java.util.function.BiConsumer<ITask<V>,java.lang.Throwable> consumer)
default @NotNull ITask<V>	onFailure(java.util.function.Consumer<java.lang.Throwable> consumer)

Methods inherited from interface java.util.concurrent.Callable

call

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Method Detail

addListener

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

addListener

@NotNull
default @NotNull ITask<V> addListener(ITaskListener<V>... listeners)

onComplete

@NotNull
default @NotNull ITask<V> onComplete(java.util.function.BiConsumer<ITask<V>,V> consumer)

onComplete

@NotNull
default @NotNull ITask<V> onComplete(java.util.function.Consumer<V> consumer)

onFailure

@NotNull
default @NotNull ITask<V> onFailure(java.util.function.BiConsumer<ITask<V>,java.lang.Throwable> consumer)

onFailure

@NotNull
default @NotNull ITask<V> onFailure(java.util.function.Consumer<java.lang.Throwable> consumer)

onCancelled

@NotNull
default @NotNull ITask<V> onCancelled(java.util.function.Consumer<ITask<V>> consumer)

fireExceptionOnFailure

default ITask<V> fireExceptionOnFailure()

clearListeners

@NotNull
@NotNull ITask<V> clearListeners()

getListeners

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

getCallable

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

getDef

V getDef(V def)

get

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

mapThrowable

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

map

default <T> ITask<T> map(@Nullable
                         @Nullable java.util.function.Function<V,T> mapper)