Struct differential_dataflow::operators::arrange::BatchWrapper

pub struct BatchWrapper<T> {
    pub item: T,
}

Wrapper type to permit transfer of Rc types, as in batch.

The BatchWrappers sole purpose in life is to implement Abomonation with methods that panic when called. This allows the wrapped data to be transited along timely's Pipeline channels. The wrapper cannot fake out Send, and so cannot be used on timely's Exchange channels, which is good.

Fields

item: T

The wrapped item.

Trait Implementations

impl<T: Clone> Clone for BatchWrapper<T>

fn clone(&self) -> BatchWrapper<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Eq> Eq for BatchWrapper<T>

impl<T: PartialEq> PartialEq for BatchWrapper<T>

fn eq(&self, __arg_0: &BatchWrapper<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, __arg_0: &BatchWrapper<T>) -> bool

This method tests for !=.

impl<T: Debug> Debug for BatchWrapper<T>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T> Abomonation for BatchWrapper<T>

unsafe fn entomb<W: Write>(&self, _write: &mut W) -> Result<()>

Write any additional information about &self beyond its binary representation.

unsafe fn exhume<'a, 'b>(
    &'a mut self,
    _bytes: &'b mut [u8]
) -> Option<&'b mut [u8]>

Recover any information for &mut self not evident from its binary representation.

fn extent(&self) -> usize

Reports the number of further bytes required to entomb self.