id_effect 0.2.0

Effect<A, E, R> (sync + async), context/layers, pipe — interpreter-style, no bundled executor
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! Ex 078 — `atomically` is [`commit`] under the Effect.ts-style name.
use id_effect::{TRef, atomically, commit, run_blocking};

fn main() {
  let stm = TRef::make(0_i32).flat_map(|cell| {
    let c2 = cell.clone();
    cell
      .write_stm::<()>(7)
      .flat_map(move |_| c2.read_stm::<()>())
  });
  let via_atomic = run_blocking(atomically(stm), ()).expect("atomically");
  let stm2 = TRef::make(0_i32).flat_map(|cell| {
    let c2 = cell.clone();
    cell
      .write_stm::<()>(7)
      .flat_map(move |_| c2.read_stm::<()>())
  });
  let via_commit = run_blocking(commit(stm2), ()).expect("commit");
  assert_eq!(via_atomic, via_commit);
  assert_eq!(via_atomic, 7);
  println!("078_stm_atomically ok");
}