com.englishtown.promises

Class OldWhenProgress<TResolve,TProgress>

java.lang.Object

com.englishtown.promises.OldWhenProgress<TResolve,TProgress>

Type Parameters:

TResolve - the type passed to fulfillment or rejection handlers

TProgress - the type passed to progress handlers

public class OldWhenProgress<TResolve,TProgress>
extends Object

A Java implementation of the CommonJS Promises/A specification. http://wiki.commonjs.org/wiki/Promises/A

Based on the when.js 1.8.1 library (c) copyright B Cavalier & J Hann (https://github.com/cujojs/when)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	OldWhenProgress.DeferredImpl Private implementation of DeferredProgress
protected class	OldWhenProgress.PromiseImpl Trusted implementation of PromiseExt.
protected class	OldWhenProgress.ResolverImpl Private implementation of Resolver

Constructor Summary

Constructors

Constructor and Description
OldWhenProgress()

Method Summary

Methods

Modifier and Type	Method and Description
ProgressPromise<List<? extends TResolve>,TProgress>	all(List<? extends ProgressPromise<TResolve,TProgress>> promises, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled) Return a promise that will resolve only once all the supplied promises have resolved.
ProgressPromise<List<? extends TResolve>,TProgress>	all(List<? extends ProgressPromise<TResolve,TProgress>> promises, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected) Return a promise that will resolve only once all the supplied promises have resolved.
ProgressPromise<List<? extends TResolve>,TProgress>	all(List<? extends ProgressPromise<TResolve,TProgress>> promises, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected, Runnable<Value<TProgress>,Value<TProgress>> onProgress) Return a promise that will resolve only once all the supplied promises have resolved.
ProgressPromise<List<? extends TResolve>,TProgress>	allValues(List<TResolve> values, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled) Return a resolved promise for the list of input values.
ProgressPromise<List<? extends TResolve>,TProgress>	any(List<? extends ProgressPromise<TResolve,TProgress>> promises, Runnable<? extends ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled) Initiates a competitive race, returning a promise that will resolve when any one of the supplied promises has resolved or will reject when *all* promises have rejected.
ProgressPromise<List<? extends TResolve>,TProgress>	any(List<? extends ProgressPromise<TResolve,TProgress>> promises, Runnable<? extends ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected) Initiates a competitive race, returning a promise that will resolve when any one of the supplied promises has resolved or will reject when *all* promises have rejected.
ProgressPromise<List<? extends TResolve>,TProgress>	any(List<? extends ProgressPromise<TResolve,TProgress>> promises, Runnable<? extends ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected, Runnable<Value<TProgress>,Value<TProgress>> onProgress) Initiates a competitive race, returning a promise that will resolve when any one of the supplied promises has resolved or will reject when *all* promises have rejected.
ProgressPromise<List<? extends TResolve>,TProgress>	anyValues(List<TResolve> values, Runnable<? extends ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled) Resolves immediately returning a resolved ProgressPromise with the first value from the input list.
ProgressPromise<TResolve,TProgress>	chain(ProgressPromise<TResolve,TProgress> promise, Resolver<TResolve,TProgress> resolver) Ensure that resolution of a promise will trigger the resolver with the resolved value.
ProgressPromise<TResolve,TProgress>	chain(ProgressPromise<TResolve,TProgress> promise, Resolver<TResolve,TProgress> resolver, TResolve resolveValue) Ensure that resolution of a promise will trigger the resolver with the provided resolveValue.
protected OldWhenProgress.PromiseImpl	createPromise(Thenable<TResolve,TProgress> then)
DeferredProgress<TResolve,TProgress>	defer() Creates a new DeferredProgress with fully isolated resolver and promise parts, either or both of which may be given out safely to consumers.
ProgressPromise<List<? extends TResolve>,TProgress>	join(ProgressPromise<TResolve,TProgress>... promises) Joins multiple promises into a single returned promise.
ProgressPromise<List<? extends TResolve>,TProgress>	join(TResolve... values) Joins multiple values into a single returned promise.
ProgressPromise<List<? extends TResolve>,TProgress>	map(List<? extends ProgressPromise<TResolve,TProgress>> promises, Runnable<ProgressPromise<TResolve,TProgress>,TResolve> mapFunc) Traditional map function, but the input is a list of ProgressPromises for values to be mapped.
ProgressPromise<List<? extends TResolve>,TProgress>	mapPromise(ProgressPromise<List<? extends TResolve>,TProgress> promise, Runnable<ProgressPromise<TResolve,TProgress>,TResolve> mapFunc) Traditional map function, but the input is a ProgressPromise for values to be mapped.
ProgressPromise<List<? extends TResolve>,TProgress>	mapValues(List<? extends TResolve> values, Runnable<ProgressPromise<TResolve,TProgress>,TResolve> mapFunc) Traditional map function, the input is a list of values to be mapped.
<T> ProgressPromise<T,TProgress>	reduce(List<ProgressPromise<TResolve,TProgress>> promises, Reducer<T,TResolve> reduceFunc) Traditional reduce function, but the input is a list of ProgressPromises.
<T> ProgressPromise<T,TProgress>	reduce(List<ProgressPromise<TResolve,TProgress>> promises, Reducer<T,TResolve> reduceFunc, ProgressPromise<T,TProgress> initialValue) Traditional reduce function, but the input is a list of ProgressPromises.
<T> ProgressPromise<T,TProgress>	reduce(List<ProgressPromise<TResolve,TProgress>> promises, Reducer<T,TResolve> reduceFunc, T initialValue) Traditional reduce function, but the input is a list of ProgressPromises.
<T> ProgressPromise<T,TProgress>	reducePromise(ProgressPromise<List<TResolve>,TProgress> promise, Reducer<T,TResolve> reduceFunc, ProgressPromise<T,TProgress> initialValue) Traditional reduce function, but the input is a ProgressPromise for a list of values.
<T> ProgressPromise<T,TProgress>	reducePromise(ProgressPromise<List<TResolve>,TProgress> promise, Reducer<T,TResolve> reduceFunc, T initialValue) Traditional reduce function, but the input is a ProgressPromise for a list of values.
<T> ProgressPromise<T,TProgress>	reduceValues(List<TResolve> values, Reducer<T,TResolve> reduceFunc) Traditional reduce function, where the input is a list of values to reduce.
<T> ProgressPromise<T,TProgress>	reduceValues(List<TResolve> values, Reducer<T,TResolve> reduceFunc, ProgressPromise<T,TProgress> initialValue) Traditional reduce function, where the input is a list of values to reduce.
<T> ProgressPromise<T,TProgress>	reduceValues(List<TResolve> values, Reducer<T,TResolve> reduceFunc, T initialValue) Traditional reduce function, where the input is a list of values to reduce.
ProgressPromise<TResolve,TProgress>	reject(Thenable<TResolve,TProgress> promise) Returns a rejected promise for the supplied promise.
ProgressPromise<TResolve,TProgress>	reject(Throwable error) Returns a rejected promise for the supplied value.
ProgressPromise<TResolve,TProgress>	reject(TResolve value) Returns a rejected promise for the supplied value.
ProgressPromise<TResolve,TProgress>	reject(Value<TResolve> value) Returns a rejected promise for the supplied value.
ProgressPromise<TResolve,TProgress>	resolve(TResolve value) Returns promiseOrValue if promiseOrValue is a ProgressPromise, a new com.englishtown.promises.ProgressPromise if promiseOrValue is a foreign promise, or a new, already-fulfilled ProgressPromise whose value is promiseOrValue if promiseOrValue is an immediate value.
ProgressPromise<TResolve,TProgress>	resolvePromise(Thenable<TResolve,TProgress> promise) Returns the promise if it is a PromiseImpl, a new PromiseImpl if it is a foreign promise, or a new, already-fulfilled ProgressPromise if it is null.
<TArg> ProgressPromise<List<TResolve>,TProgress>	sequence(List<Runnable<ProgressPromise<TResolve,TProgress>,TArg>> tasks, TArg arg) Run list of tasks in sequence with no overlap
ProgressPromise<List<TResolve>,TProgress>	sequence(List<Runnable<ProgressPromise<TResolve,TProgress>,Void>> tasks) Run list of tasks in sequence with no overlap
ProgressPromise<List<? extends TResolve>,TProgress>	some(List<? extends ProgressPromise<TResolve,TProgress>> promises, int howMany, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled) Initiates a competitive race, returning a ProgressPromise that will resolve when howMany of the supplied promises have resolved, or will reject when it becomes impossible for howMany to resolve, for example, when (promises.size() - howMany) + 1 input promises reject.
ProgressPromise<List<? extends TResolve>,TProgress>	some(List<? extends ProgressPromise<TResolve,TProgress>> promises, int howMany, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected) Initiates a competitive race, returning a ProgressPromise that will resolve when howMany of the supplied promises have resolved, or will reject when it becomes impossible for howMany to resolve, for example, when (promises.size() - howMany) + 1 input promises reject.
ProgressPromise<List<? extends TResolve>,TProgress>	some(List<? extends ProgressPromise<TResolve,TProgress>> promises, int howMany, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected, Runnable<Value<TProgress>,Value<TProgress>> onProgress) Initiates a competitive race, returning a ProgressPromise that will resolve when howMany of the supplied promises have resolved, or will reject when it becomes impossible for howMany to resolve, for example, when (promises.size() - howMany) + 1 input promises reject.
ProgressPromise<List<? extends TResolve>,TProgress>	someValues(List<TResolve> values, int howMany, Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled) Resolves immediately returning a resolved ProgressPromise with the specified number of values.
ProgressPromise<TResolve,TProgress>	when(Thenable<TResolve,TProgress> promise) Register an observer for a promise.
ProgressPromise<TResolve,TProgress>	when(Thenable<TResolve,TProgress> promise, Runnable<ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled) Register an observer for a promise.
ProgressPromise<TResolve,TProgress>	when(Thenable<TResolve,TProgress> promise, Runnable<ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled, Runnable<ProgressPromise<TResolve,TProgress>,Value<TResolve>> onRejected) Register an observer for a promise.
ProgressPromise<TResolve,TProgress>	when(Thenable<TResolve,TProgress> promise, Runnable<ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled, Runnable<ProgressPromise<TResolve,TProgress>,Value<TResolve>> onRejected, Runnable<Value<TProgress>,Value<TProgress>> onProgress) Register an observer for a promise.
ProgressPromise<TResolve,TProgress>	when(TResolve value) Register an observer for an immediate value.
ProgressPromise<TResolve,TProgress>	when(TResolve value, Runnable<ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled) Register an observer for an immediate value.

Methods inherited from class java.lang.Object

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

Constructor Detail

OldWhenProgress

public OldWhenProgress()

Method Detail

when

public ProgressPromise<TResolve,TProgress> when(TResolve value)

Register an observer for an immediate value.

Parameters:

value - the value to provide to returned promise

Returns:

a new ProgressPromise that will complete with the return value of onFulfilled or the provided value if onFulfilled is not supplied.

when

public ProgressPromise<TResolve,TProgress> when(TResolve value,
                                       Runnable<ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled)

Register an observer for an immediate value.

Parameters:

value - the value to provide to the onFulfilled callback

onFulfilled - callback to be called when value is successfully fulfilled. It will be invoked immediately.

Returns:

a new ProgressPromise that will complete with the return value of onFulfilled or the provided value if onFulfilled is not supplied.

when

public ProgressPromise<TResolve,TProgress> when(Thenable<TResolve,TProgress> promise)

Register an observer for a promise.

Parameters:

promise - a promise whose value is provided to the callbacks.

Returns:

a new ProgressPromise that will complete with the completion value of promise.

when

public ProgressPromise<TResolve,TProgress> when(Thenable<TResolve,TProgress> promise,
                                       Runnable<ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled)

Register an observer for a promise.

Parameters:

promise - a promise whose value is provided to the callbacks.

onFulfilled - callback to be called when the promise is successfully fulfilled. If the promise is an immediate value, the callback will be invoked immediately.

Returns:

a new ProgressPromise that will complete with the return value of onFulfilled or the completion value of promise if onFulfilled is not supplied.

when

public ProgressPromise<TResolve,TProgress> when(Thenable<TResolve,TProgress> promise,
                                       Runnable<ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled,
                                       Runnable<ProgressPromise<TResolve,TProgress>,Value<TResolve>> onRejected)

Register an observer for a promise.

Parameters:

promise - a promise whose value is provided to the callbacks.

onFulfilled - callback to be called when the promise is successfully fulfilled. If the promise is an immediate value, the callback will be invoked immediately.

onRejected - callback to be called when the promise is rejected.

Returns:

a new ProgressPromise that will complete with the return value of onFulfilled or onRejected or the completion value of promise if onFulfilled and/or onRejected are not supplied.

when

public ProgressPromise<TResolve,TProgress> when(Thenable<TResolve,TProgress> promise,
                                       Runnable<ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled,
                                       Runnable<ProgressPromise<TResolve,TProgress>,Value<TResolve>> onRejected,
                                       Runnable<Value<TProgress>,Value<TProgress>> onProgress)

Register an observer for a promise.

Parameters:

promise - a promise whose value is provided to the callbacks.

onFulfilled - callback to be called when the promise is successfully fulfilled. If the promise is an immediate value, the callback will be invoked immediately.

onRejected - callback to be called when the promise is rejected.

onProgress - callback to be called when progress updates are issued for the promise.

Returns:

a new ProgressPromise that will complete with the return value of onFulfilled or onRejected or the completion value of promise if onFulfilled and/or onRejected are not supplied.

resolve

public ProgressPromise<TResolve,TProgress> resolve(TResolve value)

Returns promiseOrValue if promiseOrValue is a ProgressPromise, a new com.englishtown.promises.ProgressPromise if promiseOrValue is a foreign promise, or a new, already-fulfilled ProgressPromise whose value is promiseOrValue if promiseOrValue is an immediate value.

Parameters:

value - a value to wrap in a resolved promise

Returns:

a new already-fulfilled trusted ProgressPromise for the provided value

resolvePromise

public ProgressPromise<TResolve,TProgress> resolvePromise(Thenable<TResolve,TProgress> promise)

Returns the promise if it is a PromiseImpl, a new PromiseImpl if it is a foreign promise, or a new, already-fulfilled ProgressPromise if it is null.

Parameters:

promise - the promise to resolve

Returns:

Guarantee to return a trusted PromiseImpl

reject

public ProgressPromise<TResolve,TProgress> reject(Thenable<TResolve,TProgress> promise)

Returns a rejected promise for the supplied promise. The returned promise will be rejected with the value of the promises after it is fulfilled or the reason after it is rejected.

Parameters:

promise - the rejected value of the returned ProgressPromise

Returns:

a rejected ProgressPromise

reject

public ProgressPromise<TResolve,TProgress> reject(TResolve value)

Returns a rejected promise for the supplied value. The returned promise will be rejected with the supplied value.

Parameters:

value - the rejected value of the returned ProgressPromise

Returns:

a rejected ProgressPromise

reject

public ProgressPromise<TResolve,TProgress> reject(Value<TResolve> value)

Returns a rejected promise for the supplied value. The returned promise will be rejected with the supplied value.

Parameters:

value - the rejected value of the returned ProgressPromise

Returns:

a rejected ProgressPromise

reject

public ProgressPromise<TResolve,TProgress> reject(Throwable error)

Returns a rejected promise for the supplied value. The returned promise will be rejected with the supplied error for the value.

Parameters:

error - the rejected error value of the returned ProgressPromise

Returns:

a rejected ProgressPromise

defer

public DeferredProgress<TResolve,TProgress> defer()

Creates a new DeferredProgress with fully isolated resolver and promise parts, either or both of which may be given out safely to consumers.

Returns:

new DeferredProgress

createPromise

protected OldWhenProgress.PromiseImpl createPromise(Thenable<TResolve,TProgress> then)

some

public ProgressPromise<List<? extends TResolve>,TProgress> some(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                       int howMany,
                                                       Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled)

Initiates a competitive race, returning a ProgressPromise that will resolve when howMany of the supplied promises have resolved, or will reject when it becomes impossible for howMany to resolve, for example, when (promises.size() - howMany) + 1 input promises reject.

Parameters:

promises - a list of promises

howMany - number of promises to resolve

onFulfilled - resolution handler

Returns:

a ProgressPromise that will resolve to a list of howMany values that resolved first, or will reject with an array of (promises.size() - howMany + 1) rejection reasons

some

public ProgressPromise<List<? extends TResolve>,TProgress> some(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                       int howMany,
                                                       Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled,
                                                       Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected)

Initiates a competitive race, returning a ProgressPromise that will resolve when howMany of the supplied promises have resolved, or will reject when it becomes impossible for howMany to resolve, for example, when (promises.size() - howMany) + 1 input promises reject.

Parameters:

promises - a list of promises

howMany - number of promises to resolve

onFulfilled - resolution handler

onRejected - rejection handler

Returns:

a ProgressPromise that will resolve to a list of howMany values that resolved first, or will reject with an array of (promises.size() - howMany + 1) rejection reasons

some

public ProgressPromise<List<? extends TResolve>,TProgress> some(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                       int howMany,
                                                       Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled,
                                                       Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected,
                                                       Runnable<Value<TProgress>,Value<TProgress>> onProgress)

Initiates a competitive race, returning a ProgressPromise that will resolve when howMany of the supplied promises have resolved, or will reject when it becomes impossible for howMany to resolve, for example, when (promises.size() - howMany) + 1 input promises reject.

Parameters:

promises - a list of promises

howMany - number of promises to resolve

onFulfilled - resolution handler

onRejected - rejection handler

onProgress - progress handler

Returns:

a ProgressPromise that will resolve to a list of howMany values that resolved first, or will reject with an array of (promises.size() - howMany + 1) rejection reasons

someValues

public ProgressPromise<List<? extends TResolve>,TProgress> someValues(List<TResolve> values,
                                                             int howMany,
                                                             Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled)

Resolves immediately returning a resolved ProgressPromise with the specified number of values.

Parameters:

values - a list of resolved values

howMany - number of promises to resolve

onFulfilled - resolution handler

Returns:

a resolved ProgressPromise with howMany values.

any

public ProgressPromise<List<? extends TResolve>,TProgress> any(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                      Runnable<? extends ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled)

Initiates a competitive race, returning a promise that will resolve when any one of the supplied promises has resolved or will reject when *all* promises have rejected.

Parameters:

promises - list of promises to resolve

onFulfilled - resolution handler

Returns:

a ProgressPromise that will resolve to the value that resolved first, or will reject with an array of all rejected inputs.

any

public ProgressPromise<List<? extends TResolve>,TProgress> any(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                      Runnable<? extends ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled,
                                                      Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected)

Initiates a competitive race, returning a promise that will resolve when any one of the supplied promises has resolved or will reject when *all* promises have rejected.

Parameters:

promises - list of promises to resolve

onFulfilled - resolution handler

onRejected - rejection handler

Returns:

a ProgressPromise that will resolve to the value that resolved first, or will reject with an array of all rejected inputs.

any

public ProgressPromise<List<? extends TResolve>,TProgress> any(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                      Runnable<? extends ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled,
                                                      Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected,
                                                      Runnable<Value<TProgress>,Value<TProgress>> onProgress)

Initiates a competitive race, returning a promise that will resolve when any one of the supplied promises has resolved or will reject when *all* promises have rejected.

Parameters:

promises - list of promises to resolve

onFulfilled - resolution handler

onRejected - rejection handler

onProgress - progress handler

Returns:

a ProgressPromise that will resolve to the value that resolved first, or will reject with an array of all rejected inputs.

anyValues

public ProgressPromise<List<? extends TResolve>,TProgress> anyValues(List<TResolve> values,
                                                            Runnable<? extends ProgressPromise<TResolve,TProgress>,TResolve> onFulfilled)

Resolves immediately returning a resolved ProgressPromise with the first value from the input list.

Parameters:

values - the values

onFulfilled - resolution handler

Returns:

an already-fulfilled ProgressPromise with the first value from the input list.

all

public ProgressPromise<List<? extends TResolve>,TProgress> all(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                      Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled)

Return a promise that will resolve only once all the supplied promises have resolved. The resolution value of the returned promise will be a list containing the resolution values of each of the promises.

Parameters:

promises - input promises to resolve

onFulfilled - resolution handler

Returns:

a ProgressPromise that resolves when all the input promises have resolved

all

public ProgressPromise<List<? extends TResolve>,TProgress> all(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                      Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled,
                                                      Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected)

Return a promise that will resolve only once all the supplied promises have resolved. The resolution value of the returned promise will be a list containing the resolution values of each of the promises.

Parameters:

promises - input promises to resolve

onFulfilled - resolution handler

onRejected - rejection handler

Returns:

a ProgressPromise that resolves when all the input promises have resolved

all

public ProgressPromise<List<? extends TResolve>,TProgress> all(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                      Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled,
                                                      Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,Value<List<? extends TResolve>>> onRejected,
                                                      Runnable<Value<TProgress>,Value<TProgress>> onProgress)

Return a promise that will resolve only once all the supplied promises have resolved. The resolution value of the returned promise will be a list containing the resolution values of each of the promises.

Parameters:

promises - input promises to resolve

onFulfilled - resolution handler

onRejected - rejection handler

onProgress - progress handler

Returns:

a ProgressPromise that resolves when all the input promises have resolved

allValues

public ProgressPromise<List<? extends TResolve>,TProgress> allValues(List<TResolve> values,
                                                            Runnable<? extends ProgressPromise<List<? extends TResolve>,TProgress>,List<? extends TResolve>> onFulfilled)

Return a resolved promise for the list of input values.

Parameters:

values - input values

onFulfilled - resolution handler

Returns:

a resolved ProgressPromise

join

@SafeVarargs
public final ProgressPromise<List<? extends TResolve>,TProgress> join(ProgressPromise<TResolve,TProgress>... promises)

Joins multiple promises into a single returned promise.

Parameters:

promises - the promises to join

Returns:

a ProgressPromise that will fulfill when *all* the input promises have fulfilled, or will reject when *any one* of the input promises rejects.

join

@SafeVarargs
public final ProgressPromise<List<? extends TResolve>,TProgress> join(TResolve... values)

Joins multiple values into a single returned promise.

Parameters:

values - input values to join

Returns:

a resolved ProgressPromise for the joined input values

map

public ProgressPromise<List<? extends TResolve>,TProgress> map(List<? extends ProgressPromise<TResolve,TProgress>> promises,
                                                      Runnable<ProgressPromise<TResolve,TProgress>,TResolve> mapFunc)

Traditional map function, but the input is a list of ProgressPromises for values to be mapped.

Parameters:

promises - a list of ProgressPromises

mapFunc - a mapping function that returns a promise for a value

Returns:

a ProgressPromise that will resolve to a list containing the mapped output values.

mapPromise

public ProgressPromise<List<? extends TResolve>,TProgress> mapPromise(ProgressPromise<List<? extends TResolve>,TProgress> promise,
                                                             Runnable<ProgressPromise<TResolve,TProgress>,TResolve> mapFunc)

Traditional map function, but the input is a ProgressPromise for values to be mapped.

Parameters:

promise - a ProgressPromise for a list of values to be mapped

mapFunc - a mapping function that returns a promise for a value

Returns:

a ProgressPromise that will resolve to a list containing the mapped output values.

mapValues

public ProgressPromise<List<? extends TResolve>,TProgress> mapValues(List<? extends TResolve> values,
                                                            Runnable<ProgressPromise<TResolve,TProgress>,TResolve> mapFunc)

Traditional map function, the input is a list of values to be mapped.

Parameters:

values - a list of values to be mapped

mapFunc - a mapping function that returns a promise for a value

Returns:

a resolved ProgressPromise containing the mapped output values.

reduce

public <T> ProgressPromise<T,TProgress> reduce(List<ProgressPromise<TResolve,TProgress>> promises,
                                      Reducer<T,TResolve> reduceFunc)

Traditional reduce function, but the input is a list of ProgressPromises.

Parameters:

promises - list of ProgressPromises for values to reduce

reduceFunc - the reduce function

Returns:

a ProgressPromise that will resolve to the final reduced values.

reduce

public <T> ProgressPromise<T,TProgress> reduce(List<ProgressPromise<TResolve,TProgress>> promises,
                                      Reducer<T,TResolve> reduceFunc,
                                      T initialValue)

Traditional reduce function, but the input is a list of ProgressPromises.

Parameters:

promises - list of ProgressPromises for values to reduce

reduceFunc - the reduce function

initialValue - the initial value. If null is provided, it will be used as the initial value.

Returns:

a ProgressPromise that will resolve to the final reduced values.

reduce

public <T> ProgressPromise<T,TProgress> reduce(List<ProgressPromise<TResolve,TProgress>> promises,
                                      Reducer<T,TResolve> reduceFunc,
                                      ProgressPromise<T,TProgress> initialValue)

Traditional reduce function, but the input is a list of ProgressPromises.

Parameters:

promises - list of ProgressPromises for values to reduce

reduceFunc - the reduce function

initialValue - the initial value. If null is provided, it will be used as the initial value.

Returns:

a ProgressPromise that will resolve to the final reduced values.

reduceValues

public <T> ProgressPromise<T,TProgress> reduceValues(List<TResolve> values,
                                            Reducer<T,TResolve> reduceFunc)

Traditional reduce function, where the input is a list of values to reduce.

Parameters:

values - a list of values to reduce

reduceFunc - the reduce function

Returns:

a resolved ProgressPromise for the final reduced values.

reduceValues

public <T> ProgressPromise<T,TProgress> reduceValues(List<TResolve> values,
                                            Reducer<T,TResolve> reduceFunc,
                                            T initialValue)

Traditional reduce function, where the input is a list of values to reduce.

Parameters:

values - a list of values to reduce

reduceFunc - the reduce function

initialValue - the initial value. If null is provided, it will be used as the initial value.

Returns:

a resolved ProgressPromise for the final reduced values.

reduceValues

public <T> ProgressPromise<T,TProgress> reduceValues(List<TResolve> values,
                                            Reducer<T,TResolve> reduceFunc,
                                            ProgressPromise<T,TProgress> initialValue)

Traditional reduce function, where the input is a list of values to reduce.

Parameters:

values - a list of values to reduce

reduceFunc - the reduce function

initialValue - the initial value. If null is provided, it will be used as the initial value.

Returns:

a resolved ProgressPromise for the final reduced values.

reducePromise

public <T> ProgressPromise<T,TProgress> reducePromise(ProgressPromise<List<TResolve>,TProgress> promise,
                                             Reducer<T,TResolve> reduceFunc,
                                             T initialValue)

Traditional reduce function, but the input is a ProgressPromise for a list of values.

Parameters:

promise - a ProgressPromise for values to reduce

reduceFunc - the reduce function

initialValue - the initial value. If null is provided, it will be used as the initial value.

Returns:

a ProgressPromise that will resolve to the final reduced values.

reducePromise

public <T> ProgressPromise<T,TProgress> reducePromise(ProgressPromise<List<TResolve>,TProgress> promise,
                                             Reducer<T,TResolve> reduceFunc,
                                             ProgressPromise<T,TProgress> initialValue)

Traditional reduce function, but the input is a ProgressPromise for a list of values.

Parameters:

promise - a ProgressPromise for values to reduce

reduceFunc - the reduce function

initialValue - the initial value. If null is provided, it will be used as the initial value.

Returns:

a ProgressPromise that will resolve to the final reduced values.

chain

public ProgressPromise<TResolve,TProgress> chain(ProgressPromise<TResolve,TProgress> promise,
                                        Resolver<TResolve,TProgress> resolver)

Ensure that resolution of a promise will trigger the resolver with the resolved value.

Parameters:

promise - the ProgressPromise that when resolved/rejected will trigger the resolver.

resolver - the resolver to be triggered.

Returns:

a ProgressPromise for the input promise

chain

public ProgressPromise<TResolve,TProgress> chain(ProgressPromise<TResolve,TProgress> promise,
                                        Resolver<TResolve,TProgress> resolver,
                                        TResolve resolveValue)

Ensure that resolution of a promise will trigger the resolver with the provided resolveValue.

Parameters:

promise - the ProgressPromise that when resolved/rejected will trigger the resolver.

resolver - the resolver to be triggered.

resolveValue - the value to be provided to the resolver.

Returns:

a ProgressPromise for the input promise

sequence

public ProgressPromise<List<TResolve>,TProgress> sequence(List<Runnable<ProgressPromise<TResolve,TProgress>,Void>> tasks)

Run list of tasks in sequence with no overlap

Parameters:

tasks - tasks to be executed

Returns:

ProgressPromise for a list containing the result of each task in the in the list position corresponding to the position of the task in the task list

sequence

public <TArg> ProgressPromise<List<TResolve>,TProgress> sequence(List<Runnable<ProgressPromise<TResolve,TProgress>,TArg>> tasks,
                                                        TArg arg)

Run list of tasks in sequence with no overlap

Type Parameters:

TArg - the argument type being passed to each task

Parameters:

tasks - tasks to be executed

arg - argument to be passed to all tasks

Returns:

ProgressPromise for a list containing the result of each task in the in the list position corresponding to the position of the task in the task list