tusharmath

const Rx = require('Rx')
const O = Rx.Observable
const R = require('ramda')

function SlimShady (signal$) {
  return signal$
    .delay(500).map((x) => x + 1)
}

const coprophagus = R.curry((funct, signal$) => {