class IOPromise::Faraday::ContinuableHydra

Public Class Methods

for_current_thread() click to toggle source
# File lib/iopromise/faraday/continuable_hydra.rb, line 10
def for_current_thread
  Thread.current[:faraday_promise_typhoeus_hydra] ||= new
end
new(options = {}) click to toggle source
Calls superclass method
# File lib/iopromise/faraday/continuable_hydra.rb, line 15
def initialize(options = {})
  super(options)
  
  @multi = MultiSocketAction.new(options.reject{|k,_| k==:max_concurrency})
end

Public Instance Methods

execute_continue() click to toggle source
# File lib/iopromise/faraday/continuable_hydra.rb, line 29
def execute_continue
  # fill up the curl easy handle as much as possible
  dequeue_many
    
  @multi.execute_continue
end
iop_handler=(iop_handler) click to toggle source
# File lib/iopromise/faraday/continuable_hydra.rb, line 21
def iop_handler=(iop_handler)
  @multi.iop_handler = iop_handler
end
socket_is_ready(io, readable, writable) click to toggle source
# File lib/iopromise/faraday/continuable_hydra.rb, line 25
def socket_is_ready(io, readable, writable)
  @multi.socket_is_ready(io, readable, writable)
end