termusic 0.13.2 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use tokio::sync::mpsc::UnboundedReceiver;
use tuirealm::{
    Event,
    listener::{ListenerResult, PollAsync},
};

use crate::ui::{model::UserEvent, msg::Msg};

/// tuirealm async port to provide events that are not "common" in tuirealm.
#[derive(Debug)]
pub struct PortRxMain(UnboundedReceiver<Msg>);

impl PortRxMain {
    pub fn new(rx_to_main: UnboundedReceiver<Msg>) -> Self {
        Self(rx_to_main)
    }
}

#[tuirealm::async_trait]
impl PollAsync<UserEvent> for PortRxMain {
    async fn poll(&mut self) -> ListenerResult<Option<Event<UserEvent>>> {
        match self.0.recv().await {
            Some(ev) => Ok(Some(Event::User(UserEvent::Forward(ev)))),
            None => Ok(None),
        }
    }
}