class Async::LimitedQueue
def push(item)
If the queue is full, this method will block until there is space available.
Add an item to the queue.
def push(item) while limited? @full.wait end super end
def push(item) while limited? @full.wait end super end