Struct ThreadWriterSatellite

pub struct ThreadWriterSatellite<'a, 'scope, T>
where
    T: Send + Sync + 'static,
    'scope: 'a,
{
    delegate: &'a ThreadObjectWriter<'scope, T>,
    sender: Sender<T>,
}

Child writer to allow objects to be written to a threaded writer from multiple threads, allowing parallel feeding of data. It takes a reference to the original thread writer, so it needs to be used with std::thread::scope. The original writer still needs to be closed, and this design ensures that the original cannot be closed until all the children are finished.

Fields

delegate: &'a ThreadObjectWriter<'scope, T>

sender: Sender<T>

Implementations

impl<'a, 'scope, T> ThreadWriterSatellite<'a, 'scope, T>

where T: Send + Sync + 'static, 'scope: 'a,

fn create( delegate: &'a ThreadObjectWriter<'scope, T>, ) -> ThreadWriterSatellite<'a, 'scope, T>

Create a new thread child writer.

Trait Implementations

impl<'a, 'scope, T> Clone for ThreadWriterSatellite<'a, 'scope, T>

where T: Send + Sync + 'static + Clone, 'scope: 'a,

fn clone(&self) -> ThreadWriterSatellite<'a, 'scope, T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a, 'scope, T> ObjectWriter<T> for ThreadWriterSatellite<'a, 'scope, T>

where T: Send + Sync + 'static, 'scope: 'a,

fn write_object(&mut self, object: T) -> Result<()>

Write one object.

fn finish(self) -> Result<usize>

Finish and close the target.

fn write_all_objects<I>(&mut self, objects: I) -> Result<usize>

where I: Iterator<Item = T>,

Write an iterator full of objects.

fn write_and_finish<I>(self, objects: I) -> Result<usize>

where I: Iterator<Item = T>,

Write an iterator of objects and finish the writer.

fn with_transform<F, T2>(self, transform: F) -> MapWriter<F, T2, T, Self>

where F: Fn(T2) -> Result<T>,

Wrap this object writer in a transformed writer.