Enum NetworkRecv 

pub enum NetworkRecv {
    Custom {
        deserialize_fn: Option<DebugExpr>,
    },
    Embedded {
        tag: Option<DebugType>,
        element_type: DebugType,
    },
}

How a network channel’s receiver recovers each message from the transport. See NetworkSend for the sender half.

Variants

Custom

Deserialization is performed within the Hydro dataflow using the provided deserialize expression. This is how channels using crate::networking::Bincode are lowered.

Fields

deserialize_fn: Option<DebugExpr>

Embedded

Deserialization is left to code outside of Hydro (see crate::networking::Embedded). The raw element_type is delivered to the receiver directly, with no transport Result to unwrap (the external code that produces the stream decides how to handle faults). The only transformation is converting a TaglessMemberId back into a typed crate::location::MemberId (the sender cluster tag, when the receiver is keyed by sender). Only supported by the embedded backend.

Fields

tag: Option<DebugType>

element_type: DebugType

Trait Implementations

impl Clone for NetworkRecv

fn clone(&self) -> NetworkRecv

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NetworkRecv

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Hash for NetworkRecv

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Serialize for NetworkRecv

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.