module HTTPX::Plugins::Stream::ResponseBodyMethods

  1. lib/httpx/plugins/stream.rb

Methods

Public Class

  1. new

Public Instance

  1. write

Public Class methods

new(*)
[show source] 
    # File lib/httpx/plugins/stream.rb
155 def initialize(*)
156   super
157   @stream = @response.stream
158 end

Public Instance methods

write(chunk)
[show source] 
    # File lib/httpx/plugins/stream.rb
160 def write(chunk)
161   return super unless @stream
162 
163   return 0 if chunk.empty?
164 
165   chunk = decode_chunk(chunk)
166 
167   @stream.on_chunk(chunk.dup)
168 
169   chunk.size
170 end