An example showing streaming a zipped tsv via a pipe

stream_zipped_tsv.rb

require 'async'
require 'async/http/internet/instance'
require 'csv'
require 'zlib'

def stream_zipped_tsv(url, &)
  Sync do
    response = Async::HTTP::Internet.get(url)

    unless response.success?
      response.close
      abort "Request failed: #{response.status}"
    end

    reader, writer = IO.pipe(binmode: true)

    task = Async do
      response.body.each { |chunk| writer << chunk }
    ensure
      response.close
      writer.close
    end

    stream = Zlib::GzipReader.new(reader)

    CSV.new(stream, col_sep: "\t", headers: true).each(&)
  ensure
    task&.stop
    stream&.close
    reader&.close
  end
end

url = 'https://raw.githubusercontent.com/Tapad/tapad-sample-gzip/master/file.gz'
stream_zipped_tsv(url) { |row| puts row.headers.first }