class HTTPX::Session

    # File lib/httpx/session.rb
118 def build_request(verb, uri, params = EMPTY_HASH, options = @options)
119   rklass = options.request_class
120   request = rklass.new(verb, uri, options, params)
121   request.persistent = @persistent
122   set_request_callbacks(request)
123   request
124 end

   # File lib/httpx/session.rb
64 def close(selector = Selector.new)
65   # throw resolvers away from the pool
66   @pool.reset_resolvers
67 
68   # preparing to throw away connections
69   while (connection = @pool.pop_connection)
70     next if connection.state == :closed
71 
72     select_connection(connection, selector)
73   end
74   begin
75     @closing = true
76     selector.terminate
77   ensure
78     @closing = false
79   end
80 end

    # File lib/httpx/session.rb
138 def deselect_connection(connection, selector, cloned = false)
139   connection.log(level: 2) do
140     "deregistering connection##{connection.object_id}(#{connection.state}) from selector##{selector.object_id}"
141   end
142   selector.deregister(connection)
143 
144   # when connections coalesce
145   return if connection.state == :idle
146 
147   return if cloned
148 
149   return if @closing && connection.state == :closed
150 
151   connection.log(level: 2) { "check-in connection##{connection.object_id}(#{connection.state}) in pool##{@pool.object_id}" }
152   @pool.checkin_connection(connection)
153 end

    # File lib/httpx/session.rb
155 def deselect_resolver(resolver, selector)
156   resolver.log(level: 2) do
157     "deregistering resolver##{resolver.object_id}(#{resolver.state}) from selector##{selector.object_id}"
158   end
159   selector.deregister(resolver)
160 
161   return if @closing && resolver.closed?
162 
163   resolver.log(level: 2) { "check-in resolver##{resolver.object_id}(#{resolver.state}) in pool##{@pool.object_id}" }
164   @pool.checkin_resolver(resolver)
165 end

    # File lib/httpx/session.rb
183 def find_connection(request_uri, selector, options)
184   if (connection = selector.find_connection(request_uri, options))
185     connection.idling if connection.state == :closed
186     connection.log(level: 2) { "found connection##{connection.object_id}(#{connection.state}) in selector##{selector.object_id}" }
187     return connection
188   end
189 
190   connection = @pool.checkout_connection(request_uri, options)
191 
192   connection.log(level: 2) { "found connection##{connection.object_id}(#{connection.state}) in pool##{@pool.object_id}" }
193 
194   case connection.state
195   when :idle
196     do_init_connection(connection, selector)
197   when :open
198     if options.io
199       select_connection(connection, selector)
200     else
201       pin_connection(connection, selector)
202     end
203   when :closing, :closed
204     connection.idling
205     select_connection(connection, selector)
206   else
207     pin_connection(connection, selector)
208   end
209 
210   connection
211 end

    # File lib/httpx/session.rb
131 def pin_connection(connection, selector)
132   connection.current_session = self
133   connection.current_selector = selector
134 end

    # File lib/httpx/session.rb
102 def request(*args, **params)
103   raise ArgumentError, "must perform at least one request" if args.empty?
104 
105   requests = args.first.is_a?(Request) ? args : build_requests(*args, params)
106   responses = send_requests(*requests)
107   return responses.first if responses.size == 1
108 
109   responses
110 end

    # File lib/httpx/session.rb
126 def select_connection(connection, selector)
127   pin_connection(connection, selector)
128   selector.register(connection)
129 end

    # File lib/httpx/session.rb
167 def try_clone_connection(connection, selector, family)
168   connection.family ||= family
169 
170   return connection if connection.family == family
171 
172   new_connection = connection.class.new(connection.origin, connection.options)
173 
174   new_connection.family = family
175 
176   connection.sibling = new_connection
177 
178   do_init_connection(new_connection, selector)
179   new_connection
180 end

   # File lib/httpx/session.rb
31 def wrap
32   prev_wrapped = @wrapped
33   @wrapped = true
34   was_initialized = false
35   current_selector = get_current_selector do
36     selector = Selector.new
37 
38     set_current_selector(selector)
39 
40     was_initialized = true
41 
42     selector
43   end
44   begin
45     yield self
46   ensure
47     unless prev_wrapped
48       if @persistent
49         deactivate(current_selector)
50       else
51         close(current_selector)
52       end
53     end
54     @wrapped = prev_wrapped
55     set_current_selector(nil) if was_initialized
56   end
57 end