lib/pigeon/dispatcher.rb
def wait!
    while (!@threads.empty?)
      ThreadsWait.new(@threads).join
    end
  end
# Waits until all operations have completed, including the backlog.
Waits until all operations have completed, including the backlog.
Waits until all operations have completed including the backlog .
def wait!
    while (!@threads.empty?)
      ThreadsWait.new(@threads).join
    end
  end
def wait! while ( ! @threads . empty? ) ThreadsWait . new ( @threads ) . join end end
Waits until all operations have completed, including the backlog.
Waits until all operations have completed including the backlog .