Struct Message 

pub struct Message {
    pub(crate) data: Bytes,
    pub(crate) compressed: bool,
}

Support struct used for optimising sending the same Message to multiple Stream

For an example usage see: send_raw

Fields

data: Bytes

compressed: bool

Implementations

impl Message

pub fn serialize<M: Serialize + ?Sized>( message: &M, stream_params: StreamParams, ) -> Self

This serializes any message, according to the Streams Promises. You can reuse this Message and send it via other Streams, if the Promises match. E.g. Sending a Message via a compressed and uncompressed Stream is dangerous, unless the remote site knows about this.

Example

for example coding, see send_raw

pub fn deserialize<M: DeserializeOwned>(self) -> Result<M, StreamError>

deserialize this Message. This consumes the struct, as deserialization is only expected once. Use this when deserialize a recv_raw Message. If you are resending this message, deserialization might need to copy memory

Example

// Create a Network, listen on Port `2300` and wait for a Stream to be opened, then listen on it
    let mut stream_a = participant_a.opened().await?;
    //Recv  Message
    let msg = stream_a.recv_raw().await?;
    println!("Msg is {}", msg.deserialize::<String>()?);
    drop(network);

pub(crate) fn verify(&self, params: StreamParams)