Everything as a stream

This repository presents a set of code snippets that aim to show how you can utilize RxJS and streams to build an architecture that suits your needs.

The ideas were presented at JSConf US so it's the best to explore the code in this repo along with the talk. It was developed while we embraced functional reactive programming and RxJS to build a new architecture for a large single-page application at Ardoq.

This is mainly meant to supplement the talk. We're currently in the process of packaging some of these methods and patterns as a library with proper tests and documentation.

Code snippets

• action$ - the action stream
• Routines - Routines example
• state$ - state$ example
• Views as a function of streams - Shows how you can connect a React view to a stream

Utility methods

• createStateStream - API for centralizing state stream creation
• connect - connect a React view to a stream
• createBackboneModelStream - create a proxy state observable from a Backbone model

Custom operators

• ofType - filter actions emitted from the action$ by a certain type
• catchErrorLogAndContinue - keeps your stream alive on error, useful to make your streams more robust