Package org.correomqtt.core.concurrent

Class SimpleProgressTask<P>

java.lang.Object

org.correomqtt.core.concurrent.SimpleProgressTask<P>

Direct Known Subclasses:

ConnectTask

public abstract class SimpleProgressTask<P>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final SoyEvents	soyEvents

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SimpleProgressTask(SoyEvents soyEvents)

Method Summary

Modifier and Type	Method	Description
protected void	beforeHook()
protected void	errorHook(SimpleTaskErrorResult errorResult)
protected abstract void	execute()
protected void	finalHook()
SimpleProgressTask<P>	onError(TaskErrorResultListener<SimpleTaskErrorResult> listener)
SimpleProgressTask<P>	onFinally(FinallyListener listener)
SimpleProgressTask<P>	onProgress(ProgressListener<P> listener)
SimpleProgressTask<P>	onStarted(StartListener listener)
SimpleProgressTask<P>	onSuccess(SimpleSuccessListener listener)
protected void	reportProgress(P progress)
CompletableFuture<Void>	run()
protected void	successHook()

Methods inherited from class java.lang.Object

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

Field Details

soyEvents

protected final SoyEvents soyEvents

Constructor Details

SimpleProgressTask

protected SimpleProgressTask(SoyEvents soyEvents)

Method Details

onStarted

public SimpleProgressTask<P> onStarted(StartListener listener)

onProgress

public SimpleProgressTask<P> onProgress(ProgressListener<P> listener)

onSuccess

public SimpleProgressTask<P> onSuccess(SimpleSuccessListener listener)

onError

public SimpleProgressTask<P> onError(TaskErrorResultListener<SimpleTaskErrorResult> listener)

onFinally

public SimpleProgressTask<P> onFinally(FinallyListener listener)

reportProgress

protected void reportProgress(P progress)

execute

protected abstract void execute()

beforeHook

protected void beforeHook()

successHook

protected void successHook()

errorHook

protected void errorHook(SimpleTaskErrorResult errorResult)

finalHook

protected void finalHook()

run

public CompletableFuture<Void> run()