module RabbotMetaOutputQueue::ClearWaiters

# File lib/rabbot_meta_output_queue.rb, line 10
def clear_waiters!(channel)
  channel = channel.to_s.downcase
  cleared = 0

  @mutex.synchronize do
    state = @channels[channel]
    return 0 unless state

    cleared = state[:waiters].length
    state[:waiters].clear
    cleared
  end
end