module Typhoeus::Hydra::Queueable

def abort
  queued_requests.clear
end

def dequeue
  add(queued_requests.shift) unless queued_requests.empty?
end

def dequeue_many
  number = multi.easy_handles.count
  until number == max_concurrency || queued_requests.empty?
    add(queued_requests.shift)
    number += 1
  end
end

def queue(request)
  request.hydra = self
  queued_requests << request
end

def queue_front(request)
  request.hydra = self
  queued_requests.unshift request
end

def queued_requests
  @queued_requests ||= []
end