Skip to main content

melodium_common/executive/
input.rs

1use crate::executive::RecvResult;
2use async_trait::async_trait;
3use core::fmt::Debug;
4
5use super::{TransmissionValue, Value};
6
7#[async_trait]
8pub trait Input: Debug + Send + Sync {
9    fn close(&self);
10
11    async fn recv_many(&self) -> RecvResult<TransmissionValue>;
12    async fn recv_one(&self) -> RecvResult<Value>;
13}