Struct shardio::ShardSender

pub struct ShardSender<T, S = DefaultSort> where
    T: Send + Serialize,
    S: SortKey<T>,
    <S as SortKey<T>>::Key: Ord + Clone + Serialize,  { /* fields omitted */ }

A handle that is used to send data to a ShardWriter. Each thread that is producing data needs it’s own ShardSender. A ShardSender can be obtained with the get_sender method of ShardWriter. ShardSender implement clone.

Implementations

impl<T: Send, S> ShardSender<T, S> where
    T: Send + Serialize,
    S: SortKey<T>,
    <S as SortKey<T>>::Key: Ord + Clone + Serialize, 

pub fn send(&mut self, item: T) -> Result<(), Error>

Send an item to the shard file

pub fn finished(&mut self) -> Result<(), Error>

Signal that you’ve finished sending items to this ShardSender. finished will called if the ShardSender is dropped. You must call finished() or drop the ShardSender prior to calling ShardWriter::finish or dropping the ShardWriter, or you will get a panic.

Trait Implementations

impl<T, S> Clone for ShardSender<T, S> where
    T: Send + Serialize,
    S: SortKey<T>,
    <S as SortKey<T>>::Key: Ord + Clone + Serialize, 

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Send, S: SortKey<T>> Drop for ShardSender<T, S> where
    T: Send + Serialize,
    S: SortKey<T>,
    <S as SortKey<T>>::Key: Ord + Clone + Serialize, 

fn drop(&mut self)

Executes the destructor for this type.