Struct timely::communication::Message

pub struct Message<T> { /* private fields */ }

A wrapped message which may be either typed or binary data.

Implementations

impl<T> Message<T>

pub fn from_typed(typed: T) -> Message<T>

Wrap a typed item as a message.

pub fn from_arc(typed: Arc<T>) -> Message<T>

Wrap a shared typed item as a message.

pub fn if_typed(self) -> Option<T>

Destructures and returns any typed data.

pub fn if_mut(&mut self) -> Option<&mut T>

Returns a mutable reference, if typed.

pub fn as_ref_or_mut(&mut self) -> RefOrMut<'_, T>

Returns an immutable or mutable typed reference.

This method returns a mutable reference if the underlying data are typed Rust instances, which admit mutation, and it returns an immutable reference if the data are serialized binary data.

impl<T> Message<T>

where T: Data,

pub fn from_bytes(bytes: Bytes) -> Message<T>

Wrap bytes as a message.

pub fn length_in_bytes(&self) -> usize

The number of bytes required to serialize the data.

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

where W: Write,

Writes the binary representation into writer.

impl<T> Message<T>

where T: Clone,

pub fn into_typed(self) -> T

Produces a typed instance of the wrapped element.

pub fn as_mut(&mut self) -> &mut T

Ensures the message is typed data and returns a mutable reference to it.

Trait Implementations

impl<T> Deref for Message<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &<Message<T> as Deref>::Target

Dereferences the value.

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

fn pull(&mut self) -> &mut Option<Bundle<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> Pull<Message<T>> for Puller<T>

where T: Data,

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

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> Pull<Message<T>> for PullerInner<T>

where T: Data,

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

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: Timestamp, C: Container, P> Push<Message<Message<T, C>>> for Counter<T, C, P>

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

fn push(&mut self, message: &mut Option<Bundle<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 + Data, C, P: Push<Bundle<T, C>>, H> Push<Message<Message<T, C>>> for Exchange<T, C, P, H>

where C: PushPartitioned + Container, for<'a> H: FnMut(&C::Item<'a>) -> u64,

fn push(&mut self, message: &mut Option<Bundle<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: Container, P: Push<Bundle<T, C>>> Push<Message<Message<T, C>>> for LogPusher<T, C, P>

fn push(&mut self, pair: &mut Option<Bundle<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: Data, C: Container> Push<Message<Message<T, C>>> for Tee<T, C>

fn push(&mut self, message: &mut Option<Bundle<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, P> Push<Message<T>> for Pusher<T, P>

where T: Data, P: BytesPush,

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

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.