Enum StreamMessage 

pub enum StreamMessage<'a> {
    Init {
        context_id: ContextId,
        party_id: PublicKey,
        payload: InitPayload,
        next_nonce: Nonce,
    },
    Message {
        sequence_id: u64,
        payload: MessagePayload<'a>,
        next_nonce: Nonce,
    },
    OpaqueError,
}

Top-level message for sync stream communication.

All sync protocol messages are wrapped in this enum, which provides:

• Context and identity information (in Init)
• Sequence tracking (in Message)
• Nonce for replay protection

Variants

Init

Initial message to start a sync operation.

Fields

context_id: ContextId

Context being synchronized.

party_id: PublicKey

Identity of the sending party.

payload: InitPayload

The specific request payload.

next_nonce: Nonce

Nonce for the next message.

Message

Follow-up message in an ongoing sync operation.

Fields

sequence_id: u64

Sequence number for ordering.

Wire Format Change

Changed from usize to u64 for cross-platform portability. This is a breaking wire format change - nodes must be upgraded together to avoid deserialization failures.

payload: MessagePayload<'a>

The message payload.

next_nonce: Nonce

Nonce for the next message.

OpaqueError

Opaque error - reveals nothing about node state.

Used when something goes wrong but we don’t want to leak information to potentially malicious peers.

Trait Implementations

impl<'a> BorshDeserialize for StreamMessage<'a>

fn deserialize_reader<__R: Read>(reader: &mut __R) -> Result<Self, Error>

fn deserialize(buf: &mut &[u8]) -> Result<Self, Error>

Deserializes this instance from a given slice of bytes. Updates the buffer to point at the remaining bytes.

fn try_from_slice(v: &[u8]) -> Result<Self, Error>

Deserialize this instance from a slice of bytes.

fn try_from_reader<R>(reader: &mut R) -> Result<Self, Error>

where R: Read,

impl<'a> BorshSerialize for StreamMessage<'a>

fn serialize<__W: Write>(&self, writer: &mut __W) -> Result<(), Error>

impl<'a> Debug for StreamMessage<'a>

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

Formats the value using the given formatter.

impl<'a> EnumExt for StreamMessage<'a>

fn deserialize_variant<__R: Read>( reader: &mut __R, variant_tag: u8, ) -> Result<Self, Error>

Deserialises given variant of an enum from the reader.