Struct bookdata::io::object::thread::ThreadObjectWriterBuilder

pub struct ThreadObjectWriterBuilder<W> {
    writer: W,
    name: String,
    capacity: usize,
}

Fields

writer: W

name: String

capacity: usize

Implementations

impl<W> ThreadObjectWriterBuilder<W>

pub fn with_capacity(self, cap: usize) -> Self

Set the channel capacity for this thread writer. Defaults to 100.

pub fn with_name<S: Into<Cow<'static, str>>>(self, name: S) -> Self

Set a name for this thread writer for debugging.

pub fn spawn_scoped<'scope, 'env, T>( self, scope: &'scope Scope<'scope, 'env> ) -> ThreadObjectWriter<'scope, T>

where W: ObjectWriter<T> + Send + Sync + 'scope, T: Send + Sync + 'scope,

Spawn the thread writer.

impl<W> ThreadObjectWriterBuilder<W>

pub fn spawn<T>(self) -> ThreadObjectWriter<'static, T>

where W: ObjectWriter<T> + Send + Sync + 'static, T: Send + Sync + 'static,

Spawn the thread writer.