awto

const state = run(v => s => [v, s],
                  (arg, fun) => s => {
                     const [nextArg, nextState] = arg(s)
                     return fun(nextArg)(nextState)
                   })
function set(s) { return _ => [s, s] }
function get(s) { return [s, s] }

awto

const run = (of, chain) => fun => {
  const i = fun()[Symbol.iterator]()
  return walk()
  function walk(arg) {
    const step = i.next(arg)
    return step.done ? of(step.value) : chain(step.value, walk)
  }
}

awto

arr.forEach(function* i() {
     yield i;
     yield i;
})

awto

function* dup(arr) {
  for(const i of arr) {
     yield i;
     yield i;
  }
}

awto

test("counterControl", async () => {
  expect.assertions(3)
  for await(const i of Counter.mainControl([
         {type:"MENU", value:<span>Menu</span>},
         {type:"VALUE", value:10},
         {type:"CONTROL", value:<span>Control</span>},
         {type:"FLUSH"},
         {type:"VALUE", value: 11},
         {type:"FLUSH"}]))
    if (i.type === "CONTROL")

awto

function incr(s) {
  const ns = s + 1
  return [ns, ns]
}

function incrX2(s) {
  const [s1, r1] = incr(s)
  const [s2, r2] = incr(s1)
  return [s2, r1 + r2]
}

awto

function* incr() {
  return (yield set((yield get) + 1))
}

function* incrX2() {
  return (yield* incr()) + (yield* incr())
}

const main = state(incrX2)

awto

function order(customer, item) {
    begin();
    customer.balance -= item.price;
    item.vendor.balance += item.price;
    if (customer.balance < 0)
        throw new NegativeBalance();
    scheduleShipment(customer, item)
    commit();
}

awto

export function reactiveComponent(fun) {
  class Reactive extends React.PureComponent {
    constructor(props) {
      super(props)
      this.state = {current: null}
    }
    componentDidMount() {
      (async () => {
        for await(const current of fun(this.props))
          this.setState({current})

awto

function subject(...args) {
  let callback
  const queue = []
  const iter = thread()
  let running = true
  return {
    send(event) {
      if (callback)
        callback()
      queue.push(event)