class EasyAwscr::S3::Internals::AsyncChunkUploader
- EasyAwscr::S3::Internals::AsyncChunkUploader
- EasyAwscr::S3::Internals::ChunkedIO::Handler
- Reference
- Object
Overview
This is an experimental implementation. Be warned that error handling is non-existant. The performance should be comparable to the AWS cli tool.
Defined in:
easy-awscr/s3/internals/async_chunk_uploader.crConstructors
Instance Method Summary
-
#close : Nil
Will be called once after the last write operation.
-
#open : Nil
Will be called once before the first write operation.
-
#write(buffer : IO::Memory) : IO::Memory | Nil
Can be called multiple times.
Instance methods inherited from class EasyAwscr::S3::Internals::ChunkedIO::Handler
close : Nil
close,
open : Nil
open,
write(buffer : IO::Memory) : IO::Memory | Nil
write
Constructor Detail
def self.new(client : Client, bucket : String, object : String, headers : Hash(String, String) = Hash(String, String).new, *, max_workers : Int32 = 8)
#
Instance Method Detail
def close : Nil
#
Description copied from class EasyAwscr::S3::Internals::ChunkedIO::Handler
Will be called once after the last write operation.
def open : Nil
#
Description copied from class EasyAwscr::S3::Internals::ChunkedIO::Handler
Will be called once before the first write operation.
def write(buffer : IO::Memory) : IO::Memory | Nil
#
Description copied from class EasyAwscr::S3::Internals::ChunkedIO::Handler
Can be called multiple times. The input is the current chunk.
The implementer can either process it synchronously or asynchronously.
Optionally, the function can return a buffer (either the input buffer or
another buffer of equal size) that the ChunkedIO class can reuse.
However, it is always safe to return nil and let the class
reallocate a new buffer instead.