Struct System

Source

pub struct System { /* private fields */ }

Implementations§

Source §

pub async fn run<F: FnOnce(&mut Self)>(f: F) -> Result

Builds and executes a system, blocking until completion.

Examples found in repository ?

examples/sqrt.rs (lines 8-12)

7pub async fn main() -> Result {
8    System::run(|s| {
9        let stdin = s.read_stdin::<f64>();
10        let stdout = s.write_stdout::<f64>();
11        s.spawn(sqrt(stdin, stdout));
12    })
13    .await
14}

More examples

Hide additional examples

examples/echo_lines/main.rs (lines 7-11)

6pub async fn main() -> Result {
7    System::run(|s| {
8        let stdin = s.read_stdin::<String>();
9        let stdout = s.write_stdout::<String>();
10        s.connect(stdin, stdout);
11    })
12    .await
13}

Source

pub fn build<F: FnOnce(&mut Self)>(f: F) -> Self

Builds a new system.

Source

pub fn new() -> Self

Instantiates a new system.

Source

pub fn connect<T>(&mut self, inputs: Inputs<T>, outputs: Outputs<T>)
where T: Send + 'static,

Examples found in repository ?

examples/echo_lines/main.rs (line 10)

6pub async fn main() -> Result {
7    System::run(|s| {
8        let stdin = s.read_stdin::<String>();
9        let stdout = s.write_stdout::<String>();
10        s.connect(stdin, stdout);
11    })
12    .await
13}

Source

pub fn spawn<F>(&mut self, task: F) -> AbortHandle
where F: Future<Output = Result> + Send + 'static,

Examples found in repository ?

examples/sqrt.rs (line 11)

7pub async fn main() -> Result {
8    System::run(|s| {
9        let stdin = s.read_stdin::<f64>();
10        let stdout = s.write_stdout::<f64>();
11        s.spawn(sqrt(stdin, stdout));
12    })
13    .await
14}

Source

pub async fn execute(self) -> Result

Source

pub fn read_stdin<T>(&mut self) -> Inputs<T>
where T: Send + 'static + FromStr, <T as FromStr>::Err: Send,

Examples found in repository ?

examples/sqrt.rs (line 9)

7pub async fn main() -> Result {
8    System::run(|s| {
9        let stdin = s.read_stdin::<f64>();
10        let stdout = s.write_stdout::<f64>();
11        s.spawn(sqrt(stdin, stdout));
12    })
13    .await
14}

More examples

Hide additional examples

examples/echo_lines/main.rs (line 8)

6pub async fn main() -> Result {
7    System::run(|s| {
8        let stdin = s.read_stdin::<String>();
9        let stdout = s.write_stdout::<String>();
10        s.connect(stdin, stdout);
11    })
12    .await
13}

Source

pub fn write_stdout<T>(&mut self) -> Outputs<T>
where T: Send + 'static + ToString,

Examples found in repository ?

examples/sqrt.rs (line 10)

7pub async fn main() -> Result {
8    System::run(|s| {
9        let stdin = s.read_stdin::<f64>();
10        let stdout = s.write_stdout::<f64>();
11        s.spawn(sqrt(stdin, stdout));
12    })
13    .await
14}

More examples

Hide additional examples

examples/echo_lines/main.rs (line 9)

6pub async fn main() -> Result {
7    System::run(|s| {
8        let stdin = s.read_stdin::<String>();
9        let stdout = s.write_stdout::<String>();
10        s.connect(stdin, stdout);
11    })
12    .await
13}