Channels-Repl-Like.js

import {
  alts,
  chan,
  go,
  operations,
  putAsync,
  take,
  takeAsync,
  timeout,
  CLOSED,
} from 'js-csp';

const TestChannelsBox = () => ({
  log: (name, channel, active = true) => {
    const mult = operations.mult(channel);
    let listenerChannel = chan();
    operations.mult.tap(mult, listenerChannel);

    go(function*() {
      let value = yield listenerChannel;
      while (value !== CLOSED) {
        console.log(`Channel "${name}" received value ${value}`);
        value = yield listenerChannel;
      }
      console.log('Closed Logging Channel.');
    });

    return () => {
      operations.mult.untap(mult, listenerChannel);
      listenerChannel.close();
    };
  },
  channels: {
    one: chan(),
    two: chan(),
    three: chan(),
  },
  put: putAsync,
  take: takeAsync,
  alts: (ch1, ch2) => {
    go(function*() {
      const result = yield alts([ch1, ch2]);
      console.log(
        'which channel ran first?',
        result.channel === ch1 ? 'First' : 'Second',
      );
    });
  },
  go,
  timeout,
});

window.box = TestChannelsBox();