Add example

d6u · d6u · commit 7c2c70532384 · 2016-02-23T13:21:31.000-05:00
diff --git a/.gitignore b/.gitignore
@@ -33,3 +33,4 @@ node_modules
 .node_repl_history
 
 /lib
+/demo/bundle.*
diff --git a/demo/index.html b/demo/index.html
@@ -0,0 +1,12 @@
+<html>
+<head>
+  <meta charset="UTF-8">
+  <title>React + Redux + Routility Demo</title>
+</head>
+<body>
+  <div id="app"></div>
+  <script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.0.8/rx.all.js"></script>
+  <script src="https://npmcdn.com/redux@latest/dist/redux.js"></script>
+  <script src="bundle.js"></script>
+</body>
+</html>
diff --git a/demo/script.js b/demo/script.js
@@ -0,0 +1,28 @@
+import observableMiddleware from '../src/index';
+
+const ACTION_TYPE = 'INTERVAL';
+
+function reducer(state = null, action) {
+  console.log(action);
+  switch (action.type) {
+  case `${ACTION_TYPE}_ON_NEXT`:
+    return action.data;
+  case `${ACTION_TYPE}_ON_ERROR`:
+    return state;
+  case `${ACTION_TYPE}_ON_COMPLETED`:
+    return state;
+  default:
+    return state;
+  }
+}
+
+const store = Redux.createStore(reducer, Redux.applyMiddleware(observableMiddleware));
+
+store.subscribe(() => {
+  console.log(store.getState());
+});
+
+store.dispatch({
+  type: ACTION_TYPE,
+  observable: Rx.Observable.interval(1000).take(5),
+});
diff --git a/demo/webpack.config.js b/demo/webpack.config.js
@@ -0,0 +1,24 @@
+'use strict';
+
+const join = require('path').join;
+
+module.exports = {
+  entry: join(__dirname, 'script.js'),
+
+  output: {
+    filename: 'bundle.js',
+    path: __dirname
+  },
+
+  devtool: 'source-map',
+
+  module: {
+    loaders: [
+      {
+        test: /\.js$/,
+        exclude: /node_modules/,
+        loader: 'babel',
+      }
+    ]
+  }
+};
diff --git a/package.json b/package.json
@@ -21,8 +21,10 @@
   "devDependencies": {
     "babel-cli": "^6.5.1",
     "babel-core": "^6.5.2",
+    "babel-loader": "^6.2.3",
     "babel-preset-es2015": "^6.5.0",
-    "rimraf": "^2.5.2"
+    "rimraf": "^2.5.2",
+    "webpack": "^1.12.14"
   },
   "scripts": {
     "clean": "rimraf lib",
diff --git a/src/index.js b/src/index.js
@@ -3,7 +3,7 @@ function observableMiddleware({ dispatch, getState }) {
     if (action.observable != null &&
       typeof action.observable.subscribe === 'function')
     {
-      observable.subscribe(
+      action.observable.subscribe(
         function onNext(data) {
           dispatch({ type: `${action.type}_ON_NEXT`, data });
         },

Original file line number	Diff line number	Diff line change
`@@ -33,3 +33,4 @@ node_modules`
`33`	`33`	`.node_repl_history`
`34`	`34`
`35`	`35`	`/lib`
	`36`	`+/demo/bundle.*`
Original file line number	Diff line number	Diff line change
`@@ -3,7 +3,7 @@ function observableMiddleware({ dispatch, getState }) {`
`3`	`3`	`if (action.observable != null &&`
`4`	`4`	`typeof action.observable.subscribe === 'function')`
`5`	`5`	`{`
`6`		`- observable.subscribe(`
	`6`	`+ action.observable.subscribe(`
`7`	`7`	`function onNext(data) {`
`8`	`8`	dispatch({ type: `${action.type}_ON_NEXT`, data });
`9`	`9`	`},`