Constructs a new AsyncQueue instance. Initializes an empty queue for storing promises and their resolvers.
Clears all items from the queue.
This removes all pending promises and their resolvers.
Note: This does not explicitly reject pending promises from get() calls,
so consumers awaiting get() might remain pending indefinitely if not handled.
Retrieves a value from the front of the queue. If the queue is empty, this method waits until a value is added.
A Promise that resolves with the value from the front of the queue.
Checks if the queue is currently empty. This checks if there are any resolved or pending promises in the queue.
True if the queue is empty, false otherwise.
Adds a value to the end of the queue.
If there are pending get operations, this will resolve the oldest one.
Otherwise, the value is stored until a get operation is called.
The value to add to the queue.
Gets the current number of items in the queue. This represents the number of promises (resolved or pending) currently held by the queue.
The number of items in the queue.
A simple Promise-based queue used by the Rx classes to manage asynchronous operations. This queue allows for putting and getting values in a FIFO manner, handling asynchronous operations without blocking the main thread.