Use canaries

This commit is contained in:
Joscha 2022-06-22 21:06:42 +02:00
parent a4a8174ea3
commit c0fc9589dc

View file

@ -183,6 +183,8 @@ impl State {
}; };
select! { select! {
_ = tx_canary => (),
_ = rx_canary => (),
_ = Self::listen(&mut ws_rx, &event_tx) => (), _ = Self::listen(&mut ws_rx, &event_tx) => (),
_ = Self::send_ping_events(&event_tx) => (), _ = Self::send_ping_events(&event_tx) => (),
_ = state.handle_events(&event_tx, &mut event_rx) => (), _ = state.handle_events(&event_tx, &mut event_rx) => (),