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