class HTTPX::Session

    # File lib/httpx/session.rb
114 def build_request(verb, uri, params = EMPTY_HASH, options = @options)
115   rklass = options.request_class
116   request = rklass.new(verb, uri, options, params)
117   request.persistent = @persistent
118   set_request_callbacks(request)
119   request
120 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 
75   selector_close(selector)
76 end

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

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

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

    # File lib/httpx/session.rb
130 def pin(conn_or_resolver, selector)
131   conn_or_resolver.current_session = self
132   conn_or_resolver.current_selector = selector
133 end

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

    # File lib/httpx/session.rb
122 def select_connection(connection, selector)
123   pin(connection, selector)
124   connection.log(level: 2) do
125     "registering into selector##{selector.object_id}"
126   end
127   selector.register(connection)
128 end

    # File lib/httpx/session.rb
163 def try_clone_connection(connection, selector, family)
164   connection.family ||= family
165 
166   return connection if connection.family == family
167 
168   new_connection = connection.class.new(connection.origin, connection.options)
169 
170   new_connection.family = family
171 
172   connection.sibling = new_connection
173 
174   do_init_connection(new_connection, selector)
175   new_connection
176 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