pub struct Writer<W: Write> { /* private fields */ }Expand description
Writer compresses data using the S2 stream format
The stream format includes:
- Stream identifier magic bytes
- Framed compressed blocks with CRC checksums
- Support for flushing and proper stream termination
§Example
use minlz::Writer;
use std::io::Write;
let mut compressed = Vec::new();
{
let mut writer = Writer::new(&mut compressed);
writer.write_all(b"Hello, World!").unwrap();
writer.flush().unwrap();
} // Writer is dropped and finalized here
assert!(compressed.len() > 0);Implementations§
Source§impl<W: Write> Writer<W>
impl<W: Write> Writer<W>
Sourcepub fn with_block_size(writer: W, block_size: usize) -> Self
pub fn with_block_size(writer: W, block_size: usize) -> Self
Create a new Writer with a specific block size
Block size must be between 4KB and 4MB
Sourcepub fn with_index(writer: W) -> Self
pub fn with_index(writer: W) -> Self
Create a new Writer with index support enabled
The index allows seeking in the compressed stream by recording compressed/uncompressed offset pairs at regular intervals.
§Example
use minlz::Writer;
use std::io::Write;
let mut compressed = Vec::new();
{
let mut writer = Writer::with_index(&mut compressed);
writer.write_all(b"Hello, World!").unwrap();
} // Index is appended when Writer is droppedSourcepub fn with_index_and_block_size(writer: W, block_size: usize) -> Self
pub fn with_index_and_block_size(writer: W, block_size: usize) -> Self
Create a new Writer with index support and custom block size
Sourcepub fn with_padding(writer: W, padding: usize) -> Self
pub fn with_padding(writer: W, padding: usize) -> Self
Create a new Writer with padding enabled
The output will be padded to be a multiple of padding bytes.
The padding uses skippable frames filled with random data.
Padding must be > 1 and <= 4MB.
§Example
use minlz::Writer;
use std::io::Write;
let mut compressed = Vec::new();
{
let mut writer = Writer::with_padding(&mut compressed, 1024);
writer.write_all(b"Hello, World!").unwrap();
} // Padding is applied when Writer is dropped
// Output size will be a multiple of 1024
assert_eq!(compressed.len() % 1024, 0);Sourcepub fn enable_index(&mut self)
pub fn enable_index(&mut self)
Enable index tracking on this writer
This can be called after construction to enable index support. The index will be appended when the writer is dropped.
Trait Implementations§
Source§impl<W: Write> Write for Writer<W>
impl<W: Write> Write for Writer<W>
Source§fn write(&mut self, buf: &[u8]) -> Result<usize>
fn write(&mut self, buf: &[u8]) -> Result<usize>
Writes a buffer into this writer, returning how many bytes were written. Read more
Source§fn flush(&mut self) -> Result<()>
fn flush(&mut self) -> Result<()>
Flushes this output stream, ensuring that all intermediately buffered
contents reach their destination. Read more
Source§fn is_write_vectored(&self) -> bool
fn is_write_vectored(&self) -> bool
🔬This is a nightly-only experimental API. (
can_vector)1.0.0 · Source§fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>
fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>
Attempts to write an entire buffer into this writer. Read more
Source§fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>
fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>
🔬This is a nightly-only experimental API. (
write_all_vectored)Attempts to write multiple buffers into this writer. Read more
Auto Trait Implementations§
impl<W> Freeze for Writer<W>where
W: Freeze,
impl<W> RefUnwindSafe for Writer<W>where
W: RefUnwindSafe,
impl<W> Send for Writer<W>where
W: Send,
impl<W> Sync for Writer<W>where
W: Sync,
impl<W> Unpin for Writer<W>where
W: Unpin,
impl<W> UnwindSafe for Writer<W>where
W: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more