node/Cargo.toml

@@ -16,4 +16,7 @@ workspace = true
 [dependencies.defmt]
 workspace = true
 [dependencies.uom]
-workspace = true
+workspace = true
+[dependencies.embassy-sync]
+workspace = true
+optional = true

node/src/transducer/mod.rs

@@ -3,13 +3,25 @@ mod output;
 
 pub use physical::transducer::*;
 
-// ---------------------------------------------------------------------------------------------------------------------
-// ----- Publisher ------------------------
-// ---------------------------------------------------------------------------------------------------------------------
+#[cfg(feature = "embassy-sync")]
+use embassy_sync::blocking_mutex::raw::RawMutex;
+#[cfg(feature = "embassy-sync")]
+use embassy_sync::pubsub;
+#[cfg(feature = "embassy-sync")]
+use embassy_sync::pubsub::Subscriber;
+
 #[cfg(feature = "embassy-sync")]
 pub trait Publisher {
     type Value: Copy;
+    type Mutex: RawMutex;
+    const CAPACITY: usize;
+    const NUM_SUBS: usize;
+    const NUM_PUBS: usize;
 
-
-    fn subscribe() -> SubT;
-}
+    fn subscribe(
+        &self,
+    ) -> Result<
+        Subscriber<Self::Mutex, Self::Value, Self::CAPACITY, Self::NUM_SUBS, Self::NUM_PUBS>,
+        pubsub::Error,
+    >;
+}

peripheral-components/ads1256/node/Cargo.toml

@@ -23,7 +23,4 @@ workspace = true
 [dependencies.defmt]
 workspace = true
 [dependencies.uom]
-workspace = true
-[dependencies.embassy-sync]
-workspace = true
-optional = true
+workspace = true

src/transducer/mod.rs

@@ -6,5 +6,5 @@ pub mod output;
 pub trait Stateful {
     type Value: Copy;
 
-    fn state() -> Self::Value;
+    fn state(&self) -> Self::Value;
 }

src/transducer/output.rs

@@ -3,5 +3,5 @@ pub trait Output {
 
     //TODO: return result
     //TODO: Make maybe async
-    fn set(setting: Self::Value);
+    fn set(&mut self, setting: Self::Value);
 }