TFutureAggregatorRange

An input range that aggregates results from multiple asynchronous operations, returning them in the order they arrive.

Additionally, a timeout can be set after which results from not yet finished futures will no longer be waited for, e.g. to ensure the time it takes to iterate over a set of results is limited.

final

class TFutureAggregatorRange (

) {

this(TFuture!T[] futures, TCancellationOrigin childCancellation, Duration timeout);

bool empty();

T front();

void popFront();

size_t completedCount();

Exception[] exceptions();

}

Constructors

this this(TFuture!T[] futures, TCancellationOrigin childCancellation, Duration timeout): Constructs a new instance.

Members

Functions

completedCount size_t completedCount(): The number of futures the result of which has been returned or which have failed so far.
empty bool empty(): Whether the range is empty.
exceptions Exception[] exceptions(): The exceptions collected from failed TFutures so far.
front T front(): Returns the first element from the range.
popFront void popFront(): Removes the first element from the range.

TFutureAggregatorRange

Constructors

Members

Functions

Meta

Source