@eliah_lakhin Отправляешь эвенты с кнопок в вотч-канал, а далее:

while let Some(event) = rcv.recv().await {
  futures::join_all(
    tokio::spawn(actor1.process_event(event.clone()))
    tokio::spawn(actor2.process_event(event.clone()))
    tokio::spawn(actor3.process_event(event.clone()))
  ).await;
}

можно жонглировать join, spawn и timeout в зависимости от желаемой логики обработки

хотя наверное лучше обычный mpsc использовать чтобы не пропустить ни одно событие

@vorot93 Вообще, у меня проблема не с изначальными каналами, а в том, как аккуратно организовать аборт всей системы. Я сейчас уже построил некоторый прототип того что хочу на mpsc и watch, он в принципе работает, хотя получилась довольно тяжелая мешанина из каналов

а в чём проблема с абортом? дропаешь все примитивы и всё

или у тебя вопрос как остановить таски запущенные через tokio::spawn?

ааа, вообще это проблема, да, потому что на языке асинка это называется async drop

надо городить костыли

классическая задача - дропнуть TcpStream так, чтобы отправить прощальное сообщение серверу

Таски, как мне посоветовали выше, можно останавливать через AbortHandle. Я у себя их в настоящий момент останавливаю через Tokio Notify, который сигнализирует таске о том, что ее нужно остановить. Возможно, через AbortHandle, это было бы сделать проще, я так и планирую попробовать, но проблема в том, что иногда таски ждут результата выполнения других тасок. Если ее просто прервать, то связанная таска оказывается повисшей

То есть, таска отправила некоторую информацию другой таске и Notify, которая та таска должна выполнить, чтобы изначальная узнала, что задача выполнена. Если удаленную таску остановить раньше, то изначальная никогда не закончится

Ну, это то, как я сейчас сделал, и это конечно наверное не очень правильно

кхм, я никогда не использовал notify

только oneshot

можешь заспавнить таску, положить в неё oneshot sender, и зависнуть на receiver

в твоём варианте никак

дочерняя таска или отправит значение в sender, или вообще его дропнет - первая таска в любом случае получит результат, по которому ты сможешь понять что и как

вот для этого futures-signals и делалось

@eliah_lakhin а ты не можешь просто повиснуть на JoinHandle?

у него не линейная зависимость