Struct 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 unsafe fn from_bytes(bytes: Bytes) -> Message<T>

Wrap bytes as a message.

Safety

This method is unsafe, in that Abomonated::new() is unsafe: it presumes that the binary data can be safely decoded, which is unsafe for e.g. UTF8 data and enumerations (perhaps among many other types).

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, D: Container, P: Pull<BundleCore<T, D>>> Pull<Message<Message<T, D>>> for LogPuller<T, D, P>

fn pull(&mut self) -> &mut Option<BundleCore<T, D>>

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: Eq + Data, C, D: Data, P: Push<BundleCore<T, C>>, H: FnMut(&D) -> u64> Push<Message<Message<T, C>>> for Exchange<T, C, D, P, H>

where C: PushPartitioned<Item = D> + Container,

fn push(&mut self, message: &mut Option<BundleCore<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: Timestamp, D: Container, P> Push<Message<Message<T, D>>> for CounterCore<T, D, P>

where P: Push<BundleCore<T, D>>,

fn push(&mut self, message: &mut Option<BundleCore<T, D>>)

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, D: Container, P: Push<BundleCore<T, D>>> Push<Message<Message<T, D>>> for LogPusher<T, D, P>

fn push(&mut self, pair: &mut Option<BundleCore<T, D>>)

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, D: Container> Push<Message<Message<T, D>>> for TeeCore<T, D>

fn push(&mut self, message: &mut Option<BundleCore<T, D>>)

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.