class HTTPX::StreamResponse

   # File lib/httpx/plugins/stream.rb
15 def each(&block)
16   return enum_for(__method__) unless block
17 
18   if (response_enum = @response_enum)
19     @response_enum = nil
20     # streaming already started, let's finish it
21 
22     while (chunk = @buffered_chunks.shift)
23       block.call(chunk)
24     end
25 
26     # consume enum til the end
27     begin
28       while (chunk = response_enum.next)
29         block.call(chunk)
30       end
31     rescue StopIteration
32       return
33     end
34   end
35 
36   @request.stream = self
37 
38   begin
39     @on_chunk = block
40 
41     response = @session.request(@request)
42 
43     response.raise_for_status
44   ensure
45     @on_chunk = nil
46   end
47 end

   # File lib/httpx/plugins/stream.rb
49 def each_line(&block)
50   return enum_for(__method__) unless block
51 
52   line = "".b
53 
54   each do |chunk|
55     line << chunk
56 
57     while (idx = line.index("\n"))
58       if idx.zero?
59         yield ""
60       else
61         yield line.byteslice(0..(idx - 1))
62       end
63 
64       line = line.byteslice((idx + 1)..-1)
65     end
66   end
67 
68   yield line unless line.empty?
69 end

   # File lib/httpx/plugins/stream.rb
79 def inspect
80   "#<#{self.class}:#{object_id}>"
81 end

   # File lib/httpx/plugins/stream.rb
72 def on_chunk(chunk)
73   raise NoMethodError unless @on_chunk
74 
75   @on_chunk.call(chunk)
76 end

   # File lib/httpx/plugins/stream.rb
84 def to_s
85   if @request.response
86     @request.response.to_s
87   else
88     @buffered_chunks.join
89   end
90 end