Struct autocompress::io::RayonWriter

pub struct RayonWriter<W: Write + Send + 'static, TB: ThreadBuilder = RayonThreadBuilder> { /* private fields */ }

Available on crate feature rayon only.

Off load write operation to another thread.

If you use this writer with compressor, this writer will run compression in another thread. This writer cannot parallelize compression process.

Example

use autocompress::io::RayonWriter;
use autocompress::zstd::ZstdCompressWriter;

let file_writer = File::create("target/rayon-doc-write.zst")?;
let zstd_writer = ZstdCompressWriter::new(file_writer);
let mut rayon_writer = RayonWriter::new(zstd_writer);
rayon_writer.write_all(&b"Hello, world\n"[..])?;

Implementations

impl<W: Write + Send + 'static> RayonWriter<W, RayonThreadBuilder>

pub fn with_capacity(writer: W, capacity: usize) -> Self

pub fn new(writer: W) -> Self

impl<W: Write + Send + 'static, TB: ThreadBuilder> RayonWriter<W, TB>

pub fn with_thread_builder_and_capacity( writer: W, thread_builder: TB, capacity: usize ) -> Self

pub fn into_inner(self) -> W

Trait Implementations

impl<W: Write + Send + 'static, TB: ThreadBuilder> Drop for RayonWriter<W, TB>

fn drop(&mut self)

Executes the destructor for this type.

impl<W: Write + Send + 'static, TB: ThreadBuilder> Write for RayonWriter<W, TB>

fn write(&mut self, buf: &[u8]) -> Result<usize>

Write a buffer into this writer, returning how many bytes were written.

fn flush(&mut self) -> Result<()>

Flush this output stream, ensuring that all intermediately buffered contents reach their destination.

fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> Result<usize, Error>

Like write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

🔬This is a nightly-only experimental API. (can_vector)

Determines if this Writer has an efficient write_vectored implementation.

fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>

Attempts to write an entire buffer into this writer.

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.

fn write_fmt(&mut self, fmt: Arguments<'_>) -> Result<(), Error>

Writes a formatted string into this writer, returning any error encountered.

fn by_ref(&mut self) -> &mut Self

where Self: Sized,

Creates a “by reference” adapter for this instance of Write.