notify_result.iter(0..).map(|data| my_on_notification_handler(data));
                      ^^^^ method (iter() ) not found in .......

тип
use futures::stream::{Stream}

У стрима нет iter(). Есть https://docs.rs/futures/0.3.14/futures/prelude/stream/trait.StreamExt.html#method.for_each

Вроде казалось "уже все получилось", ан нет....

notify_result.for_each(|data| my_on_notification_handler(data));
             ^^^^^^^^ () is not a future
странно, но чего-то еще не хватает...🤷‍♂️

точняк! так компилится, спасибо!

А что означает такой ворниг ?

warning: unused `ForEach` that must be used
  --> examples/subscribe_notify_characteristic.rs:118:49
   |
                                  let notify_result = peripheral.notifications().await?;
118 | / ...                   notify_result.for_each(
119 | | ...                       |data| { my_on_notification_handler(data); async {} }
120 | | ...                   );
   | |________________________^
   |
   = note: #[warn(unused_must_use)] on by default
   = note: futures do nothing unless you `.await` or poll them

ForEach — это футура, её надо поллить

т.е. .await добавь

(как и советует компилятор)

да, получилось, но выглядит причудливо...

let notify_result = peripheral.notifications().await?;
notify_result.for_each(
  |data| { my_on_notification_handler(data); async {} }
).await;

но главное что работает, данные прилетают

А почему нормально не написать?

while let Some(data) = notify_result.next().await { my_handler(data)}

👍

попробую, примеров то нет

Всем привет. Нужен совет по совместному использованию tokio и diesel. Я так понимаю, что обращения к базе нужно заворачивать в spawn_blocking, ну и избегать по возможности тяжелых запросов. Есть еще какие-то моменты, на которые стоит обратить внимание?

Стоит заменить дизель на sqlx (и аналоги), если хочется честной асинхронщины

А что для миграций посоветуете? В смысле они не нужны асинхронные, просто чтобы было удобно.

Этим кто-то пользовался https://github.com/rbatis/rbatis ?

sqlx migrate