Enum streaming_platform::ClientMsg

pub enum ClientMsg {
    MsgMeta(u64, MsgMeta),
    PayloadData(u64, usize, [u8; 1024]),
    PayloadFinished(u64, usize, [u8; 1024]),
    AttachmentData(u64, usize, usize, [u8; 1024]),
    AttachmentFinished(u64, usize, usize, [u8; 1024]),
    MessageFinished(u64),
    Message(u64, MsgMeta, Vec<u8>, Vec<u8>),
    MessageAborted(Option<u64>),
}

Messages received from client

Variants

MsgMeta(u64, MsgMeta)

This is sent in Stream mode without fs future

PayloadData(u64, usize, [u8; 1024])

This is sent in Stream mode without fs future

PayloadFinished(u64, usize, [u8; 1024])

This is sent in Stream mode without fs future

AttachmentData(u64, usize, usize, [u8; 1024])

This is sent in Stream mode without fs future. First field is index, second is number of bytes read, last is data itself.

AttachmentFinished(u64, usize, usize, [u8; 1024])

This is sent in Stream mode without fs future

MessageFinished(u64)

This is sent in Stream mode without fs future

Message(u64, MsgMeta, Vec<u8>, Vec<u8>)

This is sent in FullMessage mode without fs future

MessageAborted(Option<u64>)

Message was aborted, through cancelation or error

Implementations

impl ClientMsg

pub fn get_stream_id(&self) -> Option<u64>