PromiseQueue

Ordered promise queue, supporting asynchronous enqueuing / fulfillment.

struct PromiseQueue (

T

E = Exception

) {

alias queuePush = stackPush via import ae.utils.array : queuePush, queuePop;;

T queuePop(T[] arr) via import ae.utils.array : queuePush, queuePop;;

P fulfillOne(typeof(P.Box.tupleof) value);

}

Members

Functions

fulfillOne P fulfillOne(typeof(P.Box.tupleof) value): Fulfill one waiting promise, or enqueue a fulfilled one.
waitOne P waitOne(): Retrieve the next fulfilled promise, or enqueue a waiting one.

Meta

Source

See Implementation

ae utils promise modules

classes

Promise

functions

structs

PromiseQueue

templates