46 lines
1.1 KiB
Rust
46 lines
1.1 KiB
Rust
|
//! `Executable` is a property to execute a closure
|
||
|
|
|
||
|
|
use anyhow::Result;
|
||
|
|
|
||
|
|
use std::sync::{Arc, RwLock};
|
||
|
|
|
||
|
|
/// `Executable` holds a closure which can be executed
|
||
|
|
pub struct Executable<I> {
|
||
|
|
callback: RwLock<Option<Box<dyn Fn(I) -> Result<()> + Send + Sync>>>,
|
||
|
|
}
|
||
|
|
|
||
|
|
impl<I> Executable<I> {
|
||
|
|
/// Factory method for `Executable`, returns `Arc<Executable>`
|
||
|
|
pub fn new() -> Arc<Self> {
|
||
|
|
Arc::new(Executable {
|
||
|
|
callback: RwLock::new(None),
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
/// Set callback closure
|
||
|
|
///
|
||
|
|
/// # Arguments
|
||
|
|
///
|
||
|
|
/// * `callback` is a `Option<Callback>` closure
|
||
|
|
pub fn set_callback<F>(&self, callback: impl Into<Option<F>>)
|
||
|
|
where
|
||
|
|
F: Fn(I) -> Result<()> + Send + Sync + 'static,
|
||
|
|
{
|
||
|
|
let mut function = self.callback.write().unwrap();
|
||
|
|
|
||
|
|
match callback.into() {
|
||
|
|
Some(f) => *function = Some(Box::new(f)),
|
||
|
|
None => *function = None,
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// Execute the callback closure if possible
|
||
|
|
pub fn execute(&self, input: I) -> Result<()> {
|
||
|
|
if let Some(callback) = self.callback.read().unwrap().as_ref() {
|
||
|
|
(callback)(input)?;
|
||
|
|
}
|
||
|
|
|
||
|
|
Ok(())
|
||
|
|
}
|
||
|
|
}
|