pub(crate) async fn room_load_batch(&self, room_id_list: Vec<String>) -> Vec<Room<T>> {
        debug!("room_load_batch(room_id_list = {:?})", room_id_list);
        let mut room_list = vec![];
        let mut stream = tokio_stream::iter(room_id_list)
            .map(|room_id| self.room_load(room_id))
            .buffer_unordered(16);
        while let Some(result) = stream.next().await {
            if let Ok(room) = result {
                room_list.push(room);
            }
        }
        room_list
    }
/// Batch load rooms with a default batch size of 16.
Batch load rooms with a default batch size of 16.
Batch load rooms with a default batch size of 16 .
pub(crate) async fn room_load_batch(&self, room_id_list: Vec<String>) -> Vec<Room<T>> {
        debug!("room_load_batch(room_id_list = {:?})", room_id_list);
        let mut room_list = vec![];
        let mut stream = tokio_stream::iter(room_id_list)
            .map(|room_id| self.room_load(room_id))
            .buffer_unordered(16);
        while let Some(result) = stream.next().await {
            if let Ok(room) = result {
                room_list.push(room);
            }
        }
        room_list
    }
pub ( crate ) async fn room_load_batch ( & self , room_id_list : Vec < String > ) -> Vec < Room < T > > { debug ! ( " " room_id_list ) ; let mut room_list = vec ! [ ] ; let mut stream = tokio_stream :: iter ( room_id_list ) . map ( | room_id | self . room_load ( room_id ) ) . buffer_unordered ( 16 ) ; while let Some ( result ) = stream . next ( ) . await { if let Ok ( room ) = result { room_list . push ( room ) ; } } room_list }
Batch load rooms with a default batch size of 16.
Batch load rooms with a default batch size of 16 .
&self
room_id_list
Vec<String>
&self
room_id_list
Vec<String>