telos_agent/agent/turn/input.rs
1use tokio::sync::mpsc;
2
3pub type TurnInputSender = mpsc::UnboundedSender<String>;
4pub type TurnInputReceiver = mpsc::UnboundedReceiver<String>;
5
6pub fn turn_input_channel() -> (TurnInputSender, TurnInputReceiver) {
7 mpsc::unbounded_channel()
8}
9
10pub fn empty_turn_input_receiver() -> TurnInputReceiver {
11 let (_tx, rx) = turn_input_channel();
12 rx
13}