Sha256: 7f31e041822859f0441304fb84c801662494ea5adeca09c6ec11bfd9ce07c7dd
Contents?: true
Size: 1.78 KB
Versions: 14
Compression:
Stored size: 1.78 KB
Contents
# Can be used as a Rack response body directly. Will yield
# a {ZipTricks::Streamer} for adding entries to the archive and writing
# zip entry bodies.
class ZipTricks::RackBody
# Prepares a new Rack response body with a Zip output stream.
# The block given to the constructor will be called when the response
# body will be read by the webserver, and will receive a {ZipTricks::Streamer}
# as it's block argument. You can then add entries to the Streamer as usual.
# The archive will be automatically closed at the end of the block.
#
# # Precompute the Content-Length ahead of time
# content_length = ZipTricks::SizeEstimator.estimate do | estimator |
# estimator.add_stored_entry(filename: 'large.tif', size: 1289894)
# end
#
# # Prepare the response body. The block will only be called when the response starts to be written.
# body = ZipTricks::RackBody.new do | streamer |
# streamer.add_stored_entry(filename: 'large.tif', size: 1289894, crc32: 198210)
# streamer << large_file.read(1024*1024) until large_file.eof?
# ...
# end
#
# return [200, {'Content-Type' => 'binary/octet-stream', 'Content-Length' => content_length.to_s}, body]
def initialize(&blk)
@archiving_block = blk
end
# Connects a {ZipTricks::BlockWrite} to the Rack webserver output,
# and calls the proc given to the constructor with a {ZipTricks::Streamer}
# for archive writing.
def each(&body_chunk_block)
fake_io = ZipTricks::BlockWrite.new(&body_chunk_block)
ZipTricks::Streamer.open(fake_io, &@archiving_block)
end
# Does nothing because nothing has to be deallocated or canceled
# even if the zip output is incomplete. The archive gets closed
# automatically as part of {ZipTricks::Streamer.open}
def close
end
end
Version data entries
14 entries across 14 versions & 1 rubygems