TXRX

A very basic Sender/Receiver implementation inspired by the C++ [P2300R1] ISO paper.

API Documentation for master

Examples

All examples are located in the txrx-examples directory.

Hello world

```rust use txrx::traits::Scheduler; use txrx::SenderExt;

fn startrunner(runner: txrx::manualexecutor::Runner) { std::thread::spawn(move || loop { runner.run_one(); }); }

fn main() { let executor = txrx::manualexecutor::ManualExecutor::new(); startrunner(executor.runner());

let begin = executor.scheduler().schedule();
let hi_again = begin.map(|_| {
    println!("Hello world! Have an int");
    13
});
let add_42 = hi_again.map(|x| x + 42);

let result = add_42.sync_wait();
println!("Result: {:?}", result);

} ```

Using Rayon:

```rust use txrx_rayon::GlobalScheduler; use txrx::SenderExt; use txrx::traits::Scheduler;

fn main() { let begin = GlobalScheduler.schedule(); let hiagain = begin.map(|| { println!("Hello rayon! Have an int"); 13 }); let add42 = hiagain.map(|x| x + 42);

let result = add_42.sync_wait();
println!("Result: {:?}", result);

} ```

Async-std and Rayon

```rust use std::time::Duration; use txrx::traits::{Scheduler, Sender}; use txrx::SenderExt;

// Create some work that takes some time, using sleep to simulate long-running // compute work. fn buildwork( mut scheduler: Sched, time: u64, id: i32, ) -> impl Sender| { println!("Rayon {}: Starting some intensive work!", id); std::thread::sleep(Duration::from_secs(time)); println!("Rayon {}: Done", id); 42 + id }) }

let scheduler = txrx_rayon::GlobalScheduler::new();

let work = build_work(scheduler.clone(), 3, 1)
    .ensure_started()
    .when_both(build_work(scheduler.clone(), 2, 2).ensure_started());

println!("Rayon work started, launching timer task");
let timer_task = async_std::task::spawn(timer_task());

let result = work.into_awaitable().await; // Await result computed on rayon global thread pool
println!("Rayon work complete: {:?}", result);

timer_task.await; // Await the timer task to complete as well

println!("All work done!");