diff --git a/node/src/lib.rs b/node/src/lib.rs index 7a6c8c9..a55204f 100644 --- a/node/src/lib.rs +++ b/node/src/lib.rs @@ -1,3 +1,4 @@ +#![no_std] #![feature(async_fn_in_trait)] mod transducer; diff --git a/node/src/transducer/input.rs b/node/src/transducer/input.rs index f36bec2..a57dfa9 100644 --- a/node/src/transducer/input.rs +++ b/node/src/transducer/input.rs @@ -6,7 +6,7 @@ use embassy_sync::pubsub::PubSubChannel; pub use physical::transducer::input::*; #[cfg(feature = "embassy-sync")] -pub struct ChannelInput< +pub struct PublishInput< T: Copy, MutexT: RawMutex, const CAPACITY: usize, @@ -17,7 +17,7 @@ pub struct ChannelInput< } #[cfg(feature = "embassy-sync")] -pub struct StatefulChannelInput< +pub struct StatefulPublishInput< 'a, T: Copy, MutexT: RawMutex, diff --git a/src/lib.rs b/src/lib.rs index 6437a0e..9fe79e6 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -1,4 +1,5 @@ #![no_std] +#![feature(async_fn_in_trait)] pub mod transducer; pub mod cell; diff --git a/src/transducer/input.rs b/src/transducer/input.rs index 7f8cc1d..7b40489 100644 --- a/src/transducer/input.rs +++ b/src/transducer/input.rs @@ -1,6 +1,10 @@ use crate::cell::CellView; use crate::transducer::Stateful; +pub trait Poll { + async fn poll() -> T; +} + pub struct StatefulInput<'a, T: Copy> { pub state_cell: CellView<'a, T>, }