remap flyd functions to more convenient api

stream.js

const {
  reject,
  identical,
  keys,
  pick,
  mapObjIndexed
} = require('ramda')

const flyd = require('flyd')

const Stream = flyd.stream

const filterConstructor = reject(identical('stream'))

const addTo = (obj) => {
  return (value, key) => {
    obj[key] = value
  }
}

mapObjIndexed(addTo(Stream), pick(filterConstructor(keys(flyd)), flyd))

module.exports = Stream