Module: Typhoeus

Defined in:
lib/typhoeus.rb,
lib/typhoeus/easy.rb,
lib/typhoeus/form.rb,
lib/typhoeus/hydra.rb,
lib/typhoeus/multi.rb,
lib/typhoeus/utils.rb,
lib/typhoeus/filter.rb,
lib/typhoeus/remote.rb,
lib/typhoeus/request.rb,
lib/typhoeus/service.rb,
lib/typhoeus/response.rb,
lib/typhoeus/hydra_mock.rb,
lib/typhoeus/remote_method.rb,
lib/typhoeus/hydra/stubbing.rb,
lib/typhoeus/hydra/callbacks.rb,
lib/typhoeus/remote_proxy_object.rb,
lib/typhoeus/hydra/connect_options.rb,
lib/typhoeus/normalized_header_hash.rb

Defined Under Namespace

Modules: ClassMethods, Utils Classes: Easy, Filter, Form, Hydra, HydraMock, MockExpectedError, Multi, NormalizedHeaderHash, RemoteMethod, RemoteProxyObject, Request, Response, Service

Constant Summary collapse

USER_AGENT = 
"Typhoeus - http://github.com/dbalatero/typhoeus/tree/master"

Class Method Summary collapse

Class Method Details

.add_easy_request(easy_object) ⇒ Object 



45
46
47
48
 
# File 'lib/typhoeus.rb', line 45

def self.add_easy_request(easy_object)
  Thread.current[:curl_multi] ||= Typhoeus::Multi.new
  Thread.current[:curl_multi].add(easy_object)
end

.easy_object_pool ⇒ Object 



22
23
24
 
# File 'lib/typhoeus.rb', line 22

def self.easy_object_pool
  @easy_objects ||= []
end

.get_easy_object ⇒ Object 



37
38
39
40
41
42
43
 
# File 'lib/typhoeus.rb', line 37

def self.get_easy_object
  if easy_object_pool.empty?
    Typhoeus::Easy.new
  else
    easy_object_pool.pop
  end
end

.included(base) ⇒ Object 



4
5
6
 
# File 'lib/typhoeus/remote.rb', line 4

def self.included(base)
  base.extend ClassMethods
end

.init_easy_object_pool ⇒ Object 



26
27
28
29
30
 
# File 'lib/typhoeus.rb', line 26

def self.init_easy_object_pool
  20.times do
    easy_object_pool << Typhoeus::Easy.new
  end
end

.perform_easy_requests ⇒ Object 



50
51
52
53
54
55
56
57
 
# File 'lib/typhoeus.rb', line 50

def self.perform_easy_requests
  multi = Thread.current[:curl_multi]
  start_time = Time.now
  multi.easy_handles.each do |easy|
    easy.start_time = start_time
  end
  multi.perform
end

.release_easy_object(easy) ⇒ Object 



32
33
34
35
 
# File 'lib/typhoeus.rb', line 32

def self.release_easy_object(easy)
  easy.reset
  easy_object_pool << easy
end