class PriorityBlockingQueue

Public Instance Methods

<<(x) click to toggle source
# File lib/wattics-api-client/blocking_queue.rb, line 28
def <<(x)
  @mutex.synchronize do
    @queue << x
    @queue.flatten!
    @queue.sort!
    @received.signal
  end
end