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
212 def initialize(*)
213   super
214   @stream = @response.stream
215 end

Public Instance methods

write(chunk)
[show source] 
    # File lib/httpx/plugins/stream.rb
217 def write(chunk)
218   return super unless @stream
219 
220   return 0 if chunk.empty?
221 
222   chunk = decode_chunk(chunk)
223 
224   @stream.on_chunk(chunk.dup)
225 
226   chunk.bytesize
227 end