ages-UI-entrypoint.js

const Kefir = require('kefir')

// NO MODES
// EVERYTHING IS COMMANDS
// EVEN IF SOME COMMANDS ARE AUTO-POPULATE

function api (param) { 

  // here we can close over some mutable state
  // if we need to

  return (inputS) => {

    let outputS = Kefir.pool()
    let inputValS = Kefir.pool()

    let oneS = inputS
        .filter(x => x==1)
    outputS.plug(oneS)

    let twoS = inputS
        .filter(x => x==2)
        .map(x => x+param)
    inputValS.plug(twoS)

    return [outputS, inputValS]
  }

}


// tests
let commandS = require('kefir') // mock input
    .sequentially(100, [1,2,3])
let [outputS, inputValS] = api('some-arg')(commandS)
outputS.log('output')
inputValS.log('input value')