async fn channel_receive_prepare(&mut self, channel: Channel) -> u32 {
        let message = channel.receive().await;
        match message {
            Ok(channel_buffer) => {
                let size = channel_buffer.len();
                self.last_message.replace(channel_buffer);
                size as u32
            }
            Err(_) => panic!("Channel is closed?"),
        }
    }
/// Blocks until a message is received, then stores the message in the `last_message` field.
/// Returns the size of the message.
Blocks until a message is received, then stores the message in the `last_message` field.
Returns the size of the message.
Blocks until a message is received then stores the message in the ` last_message ` field . Returns the size of the message .
async fn channel_receive_prepare(&mut self, channel: Channel) -> u32 {
        let message = channel.receive().await;
        match message {
            Ok(channel_buffer) => {
                let size = channel_buffer.len();
                self.last_message.replace(channel_buffer);
                size as u32
            }
            Err(_) => panic!("Channel is closed?"),
        }
    }
async fn channel_receive_prepare ( & mut self , channel : Channel ) -> u32 { let message = channel . receive ( ) . await ; match message { Ok ( channel_buffer ) => { let size = channel_buffer . len ( ) ; self . last_message . replace ( channel_buffer ) ; size as u32 } Err ( _ ) => panic ! ( " " ) , } }
Blocks until a message is received, then stores the message in the `last_message` field.
Blocks until a message is received then stores the message in the ` last_message ` field .
&mut self
channel
Channel
&mut self
channel
Channel