async fn topic_partitions_list(&self, topic: &str) -> Vec<ReplicaKey> {
        self.read()
            .await
            .keys()
            .filter_map(|name| {
                if name.topic == topic {
                    Some(name.clone())
                } else {
                    None
                }
            })
            .collect()
    }
// return partitions that belong to this topic
return partitions that belong to this topic
return partitions that belong to this topic
async fn topic_partitions_list(&self, topic: &str) -> Vec<ReplicaKey> {
        self.read()
            .await
            .keys()
            .filter_map(|name| {
                if name.topic == topic {
                    Some(name.clone())
                } else {
                    None
                }
            })
            .collect()
    }
async fn topic_partitions_list ( & self , topic : & str ) -> Vec < ReplicaKey > { self . read ( ) . await . keys ( ) . filter_map ( | name | { if name . topic == topic { Some ( name . clone ( ) ) } else { None } } ) . collect ( ) }
return partitions that belong to this topic
return partitions that belong to this topic
&self
topic
&str
&self
topic
&str