org.jasync.thenables

Class Scheduled<V>

java.lang.Object

org.jasync.thenables.Scheduled<V>

All Implemented Interfaces:

Thenable<V>

public class Scheduled<V>
extends Object
implements Thenable<V>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Scheduled.Mode

Nested classes/interfaces inherited from interface org.jasync.thenables.Thenable

Thenable.Status

Method Summary

Modifier and Type	Method and Description
void	attach(Deferred<V> deferred)
static <V> Scheduled<V>	condition(java.util.function.Predicate<V> cond, java.time.Duration del, AsyncTask<V> task)
Optional<java.util.function.Predicate<V>>	getCondition()
long	getDueTime()
Scheduled.Mode	getMode()
Optional<Queue<V>>	getQueue()
Thenable.Status	getStatus()
AsyncTask<V>	getTask()
Thenable<V>	onFailure(java.util.function.Consumer<Throwable> func)
static <V> Scheduled<V>	queue(Queue<V> q)
static <V> Scheduled<V>	repeated(java.time.Duration interval, AsyncTask<V> task)
static <V> Scheduled<V>	single(java.time.Duration del, AsyncTask<V> task)
Thenable<V>	then(java.util.function.Consumer<V> func)
void	updateTimestamp()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jasync.thenables.Thenable

executionQueue, idleWait

Method Detail

getCondition

public Optional<java.util.function.Predicate<V>> getCondition()

getQueue

public Optional<Queue<V>> getQueue()

getMode

public Scheduled.Mode getMode()

getDueTime

public long getDueTime()

getTask

public AsyncTask<V> getTask()

updateTimestamp

public void updateTimestamp()

then

public Thenable<V> then(java.util.function.Consumer<V> func)

Specified by:

then in interface Thenable<V>

onFailure

public Thenable<V> onFailure(java.util.function.Consumer<Throwable> func)

Specified by:

onFailure in interface Thenable<V>

getStatus

public Thenable.Status getStatus()

Specified by:

getStatus in interface Thenable<V>

attach

public void attach(Deferred<V> deferred)

single

public static <V> Scheduled<V> single(java.time.Duration del,
                                      AsyncTask<V> task)

repeated

public static <V> Scheduled<V> repeated(java.time.Duration interval,
                                        AsyncTask<V> task)

condition

public static <V> Scheduled<V> condition(java.util.function.Predicate<V> cond,
                                         java.time.Duration del,
                                         AsyncTask<V> task)

queue

public static <V> Scheduled<V> queue(Queue<V> q)