stream.rb in httpx-0.17.0

- old
+ new

@@ -4,11 +4,10 @@
   class StreamResponse
     def initialize(request, session, connections)
       @request = request
       @session = session
       @connections = connections
-      @options = @request.options
     end
 
     def each(&block)
       return enum_for(__method__) unless block_given?
 
@@ -70,11 +69,11 @@
     end
 
     private
 
     def response
-      @session.__send__(:receive_requests, [@request], @connections, @options) until @request.response
+      @session.__send__(:receive_requests, [@request], @connections) until @request.response
 
       @request.response
     end
 
     def respond_to_missing?(meth, *args)
@@ -104,10 +103,10 @@
           requests = args.first.is_a?(Request) ? args : build_requests(*args, options)
           raise Error, "only 1 response at a time is supported for streaming requests" unless requests.size == 1
 
           request = requests.first
 
-          connections = _send_requests(requests, request.options)
+          connections = _send_requests(requests)
 
           StreamResponse.new(request, self, connections)
         end
       end
 