Struct Message 

pub struct Message<T, C> {
    pub stamp: Stamp<T>,
    pub data: C,
    pub from: usize,
    pub seq: usize,
}

A serializable representation of timestamped data.

Fields

stamp: Stamp<T>

The multiset of timestamps affixed to the message.

The message may only result in downstream work at times greater or equal to some element of the stamp. An empty stamp makes no progress claims.

data: C

The data in the message.

from: usize

The source worker.

seq: usize

A sequence number for this worker-to-worker stream.

Implementations

impl<T, C> Message<T, C>

pub fn default_length() -> usize

👎Deprecated:

Use timely::buffer::default_capacity instead

Default buffer size.

impl<T, C> Message<T, C>

pub fn new(stamp: Stamp<T>, data: C) -> Self

Creates a new message instance from arguments.

Zero values are installed for from and seq, and are meant to be populated by LogPusher.

pub fn push_at<P: Push<Message<T, C>>>( buffer: &mut C, stamp: Stamp<T>, pusher: &mut P, )

where C: Default,

Forms a message from borrowed parts, and replaces buffer with what is left by the push call. If the pusher returns nothing, then buffer is set to the default for the container.

Trait Implementations

impl<T, C> Bytesable for Message<T, C>

where T: Serialize + for<'a> Deserialize<'a> + Ord, C: ContainerBytes,

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: Clone, C: Clone> Clone for Message<T, C>

fn clone(&self) -> Message<T, C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, C: Accountable, P: Pull<Message<T, C>>> Pull<Message<T, C>> for LogPuller<P>

fn pull(&mut self) -> &mut Option<Message<T, C>>

Pulls an element and provides the opportunity to take ownership.

fn recv(&mut self) -> Option<T>

Takes an Option<T> and leaves None behind.

impl<T: 'static, C: Container> Push<Message<T, C>> for Tee<T, C>

fn push(&mut self, message: &mut Option<Message<T, C>>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.

impl<T: Eq + Clone, C, P, D> Push<Message<T, C>> for Exchange<T, P, D>

where P: Push<Message<T, C>>, D: Distributor<C>,

fn push(&mut self, message: &mut Option<Message<T, C>>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.

impl<T: Clone + Ord, C: Accountable, P> Push<Message<T, C>> for Counter<T, P>

where P: Push<Message<T, C>>,

fn push(&mut self, message: &mut Option<Message<T, C>>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.

impl<T, C: Accountable, P: Push<Message<T, C>>> Push<Message<T, C>> for LogPusher<P>

fn push(&mut self, pair: &mut Option<Message<T, C>>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.