pub(crate) async fn message_load_batch(&self, message_id_list: Vec<String>) -> Vec<Message<T>> {
        debug!("message_load_batch(message_id_list = {:?})", message_id_list);
        let mut message_list = vec![];
        let mut stream = tokio_stream::iter(message_id_list)
            .map(|message_id| self.message_load(message_id))
            .buffer_unordered(16);
        while let Some(result) = stream.next().await {
            if let Ok(message) = result {
                message_list.push(message);
            }
        }
        message_list
    }
/// Batch load messages with a default batch size of 16.
Batch load messages with a default batch size of 16.
Batch load messages with a default batch size of 16 .
pub(crate) async fn message_load_batch(&self, message_id_list: Vec<String>) -> Vec<Message<T>> {
        debug!("message_load_batch(message_id_list = {:?})", message_id_list);
        let mut message_list = vec![];
        let mut stream = tokio_stream::iter(message_id_list)
            .map(|message_id| self.message_load(message_id))
            .buffer_unordered(16);
        while let Some(result) = stream.next().await {
            if let Ok(message) = result {
                message_list.push(message);
            }
        }
        message_list
    }
pub ( crate ) async fn message_load_batch ( & self , message_id_list : Vec < String > ) -> Vec < Message < T > > { debug ! ( " " message_id_list ) ; let mut message_list = vec ! [ ] ; let mut stream = tokio_stream :: iter ( message_id_list ) . map ( | message_id | self . message_load ( message_id ) ) . buffer_unordered ( 16 ) ; while let Some ( result ) = stream . next ( ) . await { if let Ok ( message ) = result { message_list . push ( message ) ; } } message_list }
Batch load messages with a default batch size of 16.
Batch load messages with a default batch size of 16 .
&self
message_id_list
Vec<String>
&self
message_id_list
Vec<String>