Panic in take_rx()

Author: lionel-

crates/ark/src/r_task.rs

@@ -52,20 +52,17 @@ impl TaskChannels {
         self.tx.clone()
     }
 
-    fn take_rx(&self) -> Option<Receiver<RTask>> {
+    fn take_rx(&self) -> Receiver<RTask> {
         let mut rx = self.rx.lock().unwrap();
-        rx.take()
+        rx.take().expect("`take_rx()` can only be called once")
     }
 }
 
 /// Returns receivers for both interrupt and idle tasks.
 /// Initializes the task channels if they haven't been initialized yet.
 /// Can only be called once (intended for `RMain` during init).
 pub(crate) fn take_receivers() -> (Receiver<RTask>, Receiver<RTask>) {
-    (
-        INTERRUPT_TASKS.take_rx().unwrap(),
-        IDLE_TASKS.take_rx().unwrap(),
-    )
+    (INTERRUPT_TASKS.take_rx(), IDLE_TASKS.take_rx())
 }
 
 pub enum RTask {