Module: HTTPX::Plugins::Stream::ResponseBodyMethods

Defined in:
lib/httpx/plugins/stream.rb

Instance Method Summary collapse

Instance Method Details

#initialize ⇒ Object 



206
207
208
209
 
# File 'lib/httpx/plugins/stream.rb', line 206

def initialize(*)
  super
  @stream = @response.stream
end

#write(chunk) ⇒ Object 



211
212
213
214
215
216
217
218
219
220
221
 
# File 'lib/httpx/plugins/stream.rb', line 211

def write(chunk)
  return super unless @stream

  return 0 if chunk.empty?

  chunk = decode_chunk(chunk)

  @stream.on_chunk(chunk.dup)

  chunk.size
end