Type Alias timely::dataflow::channels::Bundle

pub type Bundle<T, C> = Message<Message<T, C>>;

The input to and output from timely dataflow communication channels.

Aliased Type

struct Bundle<T, C> {
    pub payload: Message<T, C>,
}

Fields

payload: Message<T, C>

Bincode contents.

Implementations

impl<T> Bincode<T>

pub fn from_typed(typed: T) -> Self

Wrap a typed item as a Bincode.

Trait Implementations

impl<T: Data> Bytesable for Bincode<T>

fn from_bytes(bytes: Bytes) -> Self

Wrap bytes as Self.

fn length_in_bytes(&self) -> usize

The number of bytes required to serialize the data.

fn into_bytes<W: Write>(&self, writer: &mut W)

Writes the binary representation into writer.

impl<T> Deref for Bincode<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.