Asynchronous queue decouples value producers and value consumers.
+Asynchronous queue decouples value producers and value consumers.
A tuple that contains a value available in the queue, and a callback that acknowledges that the value was processed and should be removed from the queue. Aborting the returned promise after a consumer received an acknowledgement callback is a no-op.
-Provides mechanism for blocking async processes and unblocking them from an external context.
+Provides mechanism for blocking async processes and unblocking them from an external context.
The promise that can be resolved externally.
+The promise that can be resolved externally.
If this value is not a promise, including undefined, it becomes the fulfillment value of the
associated promise. If this value is a promise, then the associated promise will be resolved to the passed promise,
and follow the state as the provided promise (including any future transitions).
Static [species]Static [species]Promise-based lock implementation.
+Promise-based lock implementation.
When someone tries to acquire a Lock they receive a promise for a release callback that is fulfilled as soon as previous lock owner invokes their release callback.
https://en.wikipedia.org/wiki/Lock_(computer_science) Lock (computer science)
@@ -7,4 +7,4 @@true if Lock was acquired and wasn't released yet.
Publish–subscribe pattern implementation that guarantees the delivery of published messages even if any of listeners +
Publish–subscribe pattern implementation that guarantees the delivery of published messages even if any of listeners would throw an error.
The number of subscribed listeners.
Synchronously invokes listeners with the published message.
The published message.
Waits for a message that satisfies the given predicate to be published and resolves with that message.
+An AbortablePromise that resolves with the published message that satisfies the predicate.
+Waits for a message that satisfies the given predicate to be published and resolves with that message.
+A function that takes the message as a parameter and returns true if the message satisfies the condition, otherwise false.
+An AbortablePromise that resolves with the published message that satisfies the predicate.
+The callback execution pool that can execute limited number of callbacks in parallel while other submitted callbacks +
The callback execution pool that can execute limited number of callbacks in parallel while other submitted callbacks wait in the queue.
The callback to invoke.
The promise that is fulfilled with the callback result.
-Returns a promise that is fulfilled with undefined after a timeout elapses.
Returns a promise that is fulfilled with undefined after a timeout elapses.
The timeout in milliseconds after which the returned promise is fulfilled.
The promise that is fulfilled after a timeout.
Returns a promise that is fulfilled with a value after a timeout elapses.
@@ -6,4 +6,4 @@The promise that is fulfilled with the value after the timeout elapses.
-Invokes a callback periodically with the given delay between fulfillment of returned promises until the condition is +
Invokes a callback periodically with the given delay between fulfillment of returned promises until the condition is met. If callback throws an error or returns a rejected promise, then the promise returned from repeat is rejected.
The value returned by the callback.
@@ -23,4 +23,4 @@ indefinitely.The promise that is fulfilled with the callback result.
Invokes a callback periodically until it successfully returns the result. If a callback throws an error or returns +
Invokes a callback periodically until it successfully returns the result. If a callback throws an error or returns a promise that is rejected then it is invoked again after a delay.
The promise that is fulfilled with the callback result.
Returns a promise that is fulfilled with a produced value, or rejected after the timeout elapses.
+Returns a promise that is fulfilled with a produced value, or rejected after the timeout elapses.
A callback that receives a signal that is aborted if the timeout elapses, or a promise-like object.
The timeout after which the returned promise is rejected.
The promise that is fulfilled before a timeout elapses, or rejected with a TimeoutError.
-Polls the callback until it returns a truthy value or rejects.
+Polls the callback until it returns a truthy value or rejects.
The callback that is periodically invoked.
Optional ms: number | ((value, index) => number)The number of milliseconds between the settlement of the last promise returned by the callback and the next invocation. Or a callback that receives the latest value and returns the delay. If omitted then delay is 0.
The truthy value.
-The callback that receives a signal that is aborted when execution must be stopped, and returns the execution value.
+The callback that receives a signal that is aborted when execution must be stopped, and returns the execution value.
The protocol provided to the AsyncQueue consumer, so it can acknowledge that the value was processed and +
The protocol provided to the AsyncQueue consumer, so it can acknowledge that the value was processed and should be removed from the queue.
The promise that can be aborted.
+- Preparing search index...
- The search index is not available
parallel-universe - v6.1.0Class AbortablePromise<T>
The promise that can be aborted.
Type Parameters
The value that the promise is resolved with.
Hierarchy
Index
Constructors
Accessors
Returns void
with
Subscribes this promise to be aborted when the signal is aborted.
Parameters
The signal that aborts this promise.
Returns this
This promise.
-Settings
Member Visibility
Theme
On This Page
Settings
Member Visibility
Theme
On This Page