IO wrapper sample

gistfile1.rb

class ProgressIO

  def initialize(io)
    @io = io
  end

  def read(bytes = nil, output_buffer = nil)
    puts bytes
    @io.read(bytes, output_buffer)
  end

  def rewind(*args)
    @io.rewind(*args)
  end

  def size(*args)
    @io.size(*args)
  end

end

s3 = Aws::S3::Client.new
s3.handle do |context|
  context.http_request.body = ProgressIO.new(context.http_request.body)
  @handler.call(context)
end

data = StringIO.new('.' * 1024 * 1024) # 1MB
s3.put_object(bucket:'aws-sdk', key:'key', body:data)