initial poc

.gitignore

@@ -0,0 +1 @@
+node_modules

package.json

@@ -0,0 +1,11 @@
+{
+  "name": "redux-saga-rxjs",
+  "version": "0.1.0",
+  "description": "Saga pattern for Redux implemented using rxjs",
+  "main": "index.js",
+  "author": "Tomas Weiss <tomas.weiss2@gmail.com>",
+  "license": "MIT",
+  "peerDependencies": {
+    "rxjs": "^5.0.0-beta.2"
+  }
+}

src/main.js

@@ -0,0 +1,15 @@
+import { Subject } from 'rxjs';
+
+const sagaMiddleware = (...sagas) => {
+  const subject = new Subject();
+
+  return store => {
+    sagas.forEach(saga =>
+        saga(subject).subscribe(dispatchable => store.dispatch(dispatchable));
+
+    return next => action => {
+      next(action);
+      subject.next(action, store.getState());
+    };
+  };
+};