Struct Dispatcher 

pub struct Dispatcher { /* private fields */ }

Implementations

impl Dispatcher

pub fn new<H: Into<BoxSafeRunnableCommand>>(h: H) -> Result<Self, Error>

Examples found in repository

examples/simple.rs (line 38)

async fn main() -> anyhow::Result<()> {
    let dispatcher = Dispatcher::new(RootCommand::default())?.register(HiCommand::default())?;
    // dispatcher.dispatch_with_stdio().await?;
    let buf = vec![];
    let w = tokio::io::BufWriter::new(buf);
    let w = std::sync::Arc::new(tokio::sync::Mutex::new(w));
    let _cx = dispatcher
        .dispatch(&["rt", "--debug", "hi", "--name", "me"], w.clone())
        .await?;
    w.lock().await.flush().await?;
    let output = String::from_utf8(w.lock().await.get_ref().to_owned())?;
    debug_assert_eq!(output, "hi me");
    println!("{}", output);
    Ok(())
}

pub fn register<H: Into<BoxSafeRunnableCommand>>( self, h: H, ) -> Result<Self, Error>

Examples found in repository

examples/simple.rs (line 38)

async fn main() -> anyhow::Result<()> {
    let dispatcher = Dispatcher::new(RootCommand::default())?.register(HiCommand::default())?;
    // dispatcher.dispatch_with_stdio().await?;
    let buf = vec![];
    let w = tokio::io::BufWriter::new(buf);
    let w = std::sync::Arc::new(tokio::sync::Mutex::new(w));
    let _cx = dispatcher
        .dispatch(&["rt", "--debug", "hi", "--name", "me"], w.clone())
        .await?;
    w.lock().await.flush().await?;
    let output = String::from_utf8(w.lock().await.get_ref().to_owned())?;
    debug_assert_eq!(output, "hi me");
    println!("{}", output);
    Ok(())
}

pub async fn dispatch_with_stdio(self) -> Result<Context, Error>

pub async fn dispatch<I, T, O>( self, i: I, o: Arc<Mutex<O>>, ) -> Result<Context, Error>

where O: OutputBound, I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Examples found in repository

examples/simple.rs (line 44)

async fn main() -> anyhow::Result<()> {
    let dispatcher = Dispatcher::new(RootCommand::default())?.register(HiCommand::default())?;
    // dispatcher.dispatch_with_stdio().await?;
    let buf = vec![];
    let w = tokio::io::BufWriter::new(buf);
    let w = std::sync::Arc::new(tokio::sync::Mutex::new(w));
    let _cx = dispatcher
        .dispatch(&["rt", "--debug", "hi", "--name", "me"], w.clone())
        .await?;
    w.lock().await.flush().await?;
    let output = String::from_utf8(w.lock().await.get_ref().to_owned())?;
    debug_assert_eq!(output, "hi me");
    println!("{}", output);
    Ok(())
}