Basic RxJS with Flux example

index.js

// Store
import AppDispatcher from './dispatcher/AppDispatcher'
const list$ = Rx.Subject.startWith([])

function addElement (action) {
  const newElement = action.data
  const currentValue = list$.getValue()
  list$.onNext(currentValue.concat(newElement))
}

AppDispatcher.register((action) => {
  switch (action.type) {
    case 'addElement'
     addElement(action)
  }
})

return {
  subscribe: list$.subscribe,
  currentData: list$.getValue
}

// Component
import elementsStore from 'store/elementsStore'

const appComponent = React.createElement({
  getInitialState () {
    return {
      list: elementsStore.currentData()
    }
  }
  componentDidMount () {
    this.streamObservable = elementsStore.subscribe((data) => {
      this.setState({
        list: data
      })
    })
  }
  componentWillUnmount () {
    this.streamObservable.disposeStream()
  }
  render () {
    return (<ListElements list={this.state.list}) />
  }
})

const ListElements = ({list}) => {
  return (
    list.map((element) => <Element data={element} />)
  )
}