module Typhoeus::Hydras::Queueable

def abort

Other tags:
    Example: Abort hydra. - 
def abort
  queued_requests.clear
end

def queue(request)

Other tags:
    Example: Queue request. - 
def queue(request)
  request.hydra = self
  if multi.easy_handles.size < max_concurrency
    multi.add(Hydras::EasyFactory.new(request, self).get)
  else
    queued_requests << request
  end
end

def queued_requests

Returns:
  • (Array) - The queued requests.

Other tags:
    Example: Return queued requests. - 
def queued_requests
  @queued_requests ||= []
end