let broadcast_incoming = read
.try_filter_map(|msg| {
let result = match msg {
tokio_tungstenite::tungstenite::Message::Pong(_) => Some(Ok(sqlx::query_file!(
"sql/insert_ping.sql",
IMEI.to_string()
))),
tokio_tungstenite::tungstenite::Message::Binary(bytes) => {
Some(handle_binary_message(&bytes))
}
whatever => {
println!("whatever {:?}", whatever);
None
}
};
future::ok(result)
})
.map(|result| {
result.unwrap().unwrap().execute(pool);
});
Я переписал его вот так let handle_incoming = read .map(to_query) .for_each(|result| { // future::ready(()) result.unwrap().execute(pool); future::ready(()) }); Но я не могу понять как превратить из асинхронного result.unwrap().execute(pool); что-то похожее на future::ready(())
Обсуждают сегодня