qubit_function/tasks/runnable_with/
rc_runnable_with.rs

1/*******************************************************************************
2 *
3 *    Copyright (c) 2025 - 2026 Haixing Hu.
4 *
5 *    SPDX-License-Identifier: Apache-2.0
6 *
7 *    Licensed under the Apache License, Version 2.0.
8 *
9 ******************************************************************************/
10// qubit-style: allow explicit-imports
11//! Defines the `RcRunnableWith` public type.
12
13#![allow(unused_imports)]
14
15use super::*;
16
17/// Single-threaded shared runnable with mutable input.
18///
19/// `RcRunnableWith<T, E>` stores a
20/// `Rc<RefCell<dyn FnMut(&mut T) -> Result<(), E>>>`.
21///
22pub struct RcRunnableWith<T, E> {
23    /// The stateful closure executed by this runnable.
24    pub(super) function: Rc<RefCell<dyn FnMut(&mut T) -> Result<(), E>>>,
25    /// The optional name of this runnable.
26    pub(super) name: Option<String>,
27}
28
29impl<T, E> Clone for RcRunnableWith<T, E> {
30    #[inline]
31    fn clone(&self) -> Self {
32        Self {
33            function: Rc::clone(&self.function),
34            name: self.name.clone(),
35        }
36    }
37}
38
39impl<T, E> RcRunnableWith<T, E> {
40    impl_common_new_methods!(
41        (FnMut(&mut T) -> Result<(), E> + 'static),
42        |function| Rc::new(RefCell::new(function)),
43        "runnable-with"
44    );
45
46    impl_common_name_methods!("runnable-with");
47}
48
49impl<T, E> RunnableWith<T, E> for RcRunnableWith<T, E> {
50    /// Executes the shared runnable with mutable input.
51    #[inline]
52    fn run_with(&mut self, input: &mut T) -> Result<(), E> {
53        (self.function.borrow_mut())(input)
54    }
55
56    impl_rc_conversions!(
57        RcRunnableWith<T, E>,
58        BoxRunnableWith,
59        FnMut(input: &mut T) -> Result<(), E>
60    );
61}
qubit_function/tasks/runnable_with/rc_runnable_with.rs

qubit_function/tasks/runnable_with/
rc_runnable_with.rs
