Merge pull request #23 from reallistic/master

Recreate Rx.Subject on componentWillMount

Author: kiddkai

dist/mixins/events.js

@@ -14,18 +14,20 @@ var _rx2 = _interopRequireDefault(_rx);
 function events() {
  var evs = arguments.length <= 0 || arguments[0] === undefined ? [] : arguments[0];
 
- var streams = evs.reduce(function (res, eventName) {
- res[eventName] = new _rx2['default'].Subject();
- return res;
- }, {});
-
  return {
  componentWillMount: function componentWillMount() {
- Object.assign(this, streams);
+ var streams = evs.reduce(function (res, eventName) {
+ res[eventName] = new _rx2['default'].Subject();
+ return res;
+ }, {});
+
+ Object.assign(this, streams, { __streams: streams });
  },
  componentWillUnmount: function componentWillUnmount() {
+ var _this = this;
+
  evs.forEach(function (ev) {
- return streams[ev].onCompleted();
+ return _this.__streams[ev].onCompleted();
  });
  }
  };

src/mixins/events.js

@@ -1,17 +1,17 @@
 import Rx from 'rx'
 
 export default function events (evs = []) {
- var streams = evs.reduce(function (res, eventName) {
- res[eventName] = new Rx.Subject()
- return res
- }, {})
-
  return {
  componentWillMount () {
- Object.assign(this, streams)
+ var streams = evs.reduce(function (res, eventName) {
+ res[eventName] = new Rx.Subject()
+ return res
+ }, {})
+
+ Object.assign(this, streams, {__streams: streams})
  },
  componentWillUnmount () {
- evs.forEach((ev) => streams[ev].onCompleted())
+ evs.forEach((ev) => this.__streams[ev].onCompleted())
  }
  }
 }