pub async fn listen(mut self) {

Question

pub async fn listen(mut self) {

while let Ok(notification) = self.event_loop.poll().await {
if let Event::Incoming(Incoming::Publish(publish)) = notification {
for (regex, handler) in &self.handlers {
if let Some(matches) = regex.find(&publish.topic) {
let matches = publish.topic[matches.range()].to_string();
match handler(self.state.clone(), &self, &publish, matches) {
Ok(fut) => {
if let Err(e) = fut.await {
println!("{:?}", &e);
}
}
Err(e) => println!("{:?}", &e),
}
}
}
}
}
}

#backend #embedded #programming #russian #rust

0

21.11.2023

1 ответов

26 просмотров

Tech Makaka · Answer 1

Почему тогда этот метод не ломался? pub async fn listen(mut self) { while let Ok(notification) = self.event_loop.poll().await { // &mut self.event_loop if let Event::Incoming(Incoming::Publish(publish)) = notification { for (regex, handler) in &self.handlers { if let Some(matches) = regex.find(&publish.topic) { let matches = publish.topic[matches.range()].to_string(); match handler(self.state.clone(), &self, &publish, matches) { // &self Ok(fut) => { if let Err(e) = fut.await { println!("{:?}", &e); } } Err(e) => println!("{:?}", &e), } } } } } }

172 похожих чатов

pub async fn listen(mut self) {

1 ответов

Похожие вопросы