Method: Async::LimitedQueue#push
- Defined in:
- lib/async/queue.rb
#push(item) ⇒ Object
Add an item to the queue.
If the queue is full, this method will block until there is space available.
132 133 134 135 136 137 138 |
# File 'lib/async/queue.rb', line 132 def push(item) while limited? @full.wait end super end |