rsiot/components/cmp_esp_uart_slave/tasks/
input.rs

1use crate::{executor::CmpInOut, message::MsgDataBound};
2
3use super::{super::config::TFnInput, Buffer};
4
5pub struct Input<TMsg, TBufferData>
6where
7    TMsg: MsgDataBound,
8{
9    pub buffer_data: Buffer<TBufferData>,
10    pub msg_bus: CmpInOut<TMsg>,
11    pub fn_input: TFnInput<TMsg, TBufferData>,
12}
13
14impl<TMsg, TBufferData> Input<TMsg, TBufferData>
15where
16    TMsg: MsgDataBound,
17{
18    pub async fn spawn(mut self) -> super::Result<()> {
19        while let Ok(msg) = self.msg_bus.recv_input().await {
20            let mut buffer_data = self.buffer_data.lock().await;
21            (self.fn_input)(&msg, &mut buffer_data);
22        }
23        Ok(())
24    }
25}