Init implementation

Author: d6u

Diff for: .babelrc

@@ -0,0 +1,3 @@
+{
+  "presets": ["es2015"]
+}

Diff for: .gitignore

@@ -31,3 +31,5 @@ node_modules
 
 # Optional REPL history
 .node_repl_history
+
+/lib

Diff for: package.json

@@ -0,0 +1,35 @@
+{
+  "name": "redux-observable-middleware",
+  "version": "0.0.0",
+  "description": "",
+  "main": "./lib/index.js",
+  "files": [
+    "lib",
+    "src"
+  ],
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/d6u/redux-observable-middleware.git"
+  },
+  "author": "Daiwei Lu <[email protected]> (http://daiwei.lu)",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/d6u/redux-observable-middleware/issues"
+  },
+  "homepage": "https://github.com/d6u/redux-observable-middleware#readme",
+  "dependencies": {},
+  "devDependencies": {
+    "babel-cli": "^6.5.1",
+    "babel-core": "^6.5.2",
+    "babel-preset-es2015": "^6.5.0",
+    "rimraf": "^2.5.2"
+  },
+  "scripts": {
+    "clean": "rimraf lib",
+    "build:lib": "babel src --out-dir lib",
+    "build": "npm run build:lib",
+    "preversion": "npm run check",
+    "postversion": "git push && git push --tags",
+    "prepublish": "npm run clean && npm run build"
+  }
+}

Diff for: src/index.js

@@ -0,0 +1,23 @@
+function observableMiddleware({ dispatch, getState }) {
+  return (next) => (action) => {
+    if (action.observable != null &&
+      typeof action.observable.subscribe === 'function')
+    {
+      observable.subscribe(
+        function onNext(data) {
+          dispatch({ type: `${action.type}_ON_NEXT`, data });
+        },
+        function onError(err) {
+          dispatch({ type: `${action.type}_ON_ERROR`, err });
+        },
+        function onCompleted() {
+          dispatch({ type: `${action.type}_ON_COMPLETED` });
+        }
+      );
+    }
+
+    next(action);
+  }
+}
+
+module.exports = observableMiddleware;