react/rxjs wrapper

echo.coffee

_ = require 'lodash'
{addons: {cloneWithProps}} = require 'react'

echoEvent = (rxId, eventStream, eventName, ev) ->
  eventStream.onNext {
    ev
    rxId
    type: eventName
  }

module.exports = Echo = ({rxId, eventStream, events}, element) ->
  newProps = {}

  events = if _.isArray events
    events
  else if _.isString events
    [events]
  else
    []

  for eventName in events
    newProps[eventName] = echoEvent.bind(null, rxId, eventStream, eventName)
  
  cloneWithProps(
    element
    newProps
  )