Struct System 

pub struct System { /* private fields */ }

Implementations

impl System

pub fn oneshot<T>() -> Channel<T, async_flow::::tokio::system::{impl#0}::oneshot::{constant#0}>

pub fn bounded<T>( buffer: usize, ) -> Channel<T, async_flow::::tokio::system::{impl#0}::bounded::{constant#0}>

pub async fn run<F>(f: F) -> Result<(), Error>

where F: FnOnce(&mut System),

Builds and executes a system, blocking until completion.

pub fn build<F>(f: F) -> System

where F: FnOnce(&mut System),

Builds a new system.

pub fn new() -> System

Instantiates a new system.

pub fn connect<T>(&mut self, inputs: Inputs<T>, outputs: Outputs<T>)

where T: Send + 'static,

pub fn spawn<F>(&mut self, task: F) -> AbortHandle

where F: Future<Output = Result<(), Error>> + Send + 'static,

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

pub fn read_stdin<T>(&mut self) -> Inputs<T>

where T: FromStr + Send + 'static, <T as FromStr>::Err: Send,

pub fn write_stdout<T>(&mut self) -> Outputs<T>

where T: ToString + Send + 'static,