Comparing version 0.1.3 to 0.2.0
@@ -50,81 +50,82 @@ 'use strict'; | ||
function getSaga(resolve, reject, effects, model, onError, onEffect) { | ||
return _regenerator2.default.mark(function _callee3() { | ||
var _this = this; | ||
return (/*#__PURE__*/_regenerator2.default.mark(function _callee3() { | ||
var _this = this; | ||
var key; | ||
return _regenerator2.default.wrap(function _callee3$(_context3) { | ||
while (1) { | ||
switch (_context3.prev = _context3.next) { | ||
case 0: | ||
_context3.t0 = _regenerator2.default.keys(effects); | ||
var key; | ||
return _regenerator2.default.wrap(function _callee3$(_context3) { | ||
while (1) { | ||
switch (_context3.prev = _context3.next) { | ||
case 0: | ||
_context3.t0 = _regenerator2.default.keys(effects); | ||
case 1: | ||
if ((_context3.t1 = _context3.t0()).done) { | ||
_context3.next = 7; | ||
break; | ||
} | ||
case 1: | ||
if ((_context3.t1 = _context3.t0()).done) { | ||
_context3.next = 7; | ||
break; | ||
} | ||
key = _context3.t1.value; | ||
key = _context3.t1.value; | ||
if (!Object.prototype.hasOwnProperty.call(effects, key)) { | ||
_context3.next = 5; | ||
break; | ||
} | ||
if (!Object.prototype.hasOwnProperty.call(effects, key)) { | ||
_context3.next = 5; | ||
break; | ||
} | ||
return _context3.delegateYield(_regenerator2.default.mark(function _callee2() { | ||
var watcher, task; | ||
return _regenerator2.default.wrap(function _callee2$(_context2) { | ||
while (1) { | ||
switch (_context2.prev = _context2.next) { | ||
case 0: | ||
watcher = getWatcher(resolve, reject, key, effects[key], model, onError, onEffect); | ||
_context2.next = 3; | ||
return sagaEffects.fork(watcher); | ||
return _context3.delegateYield( /*#__PURE__*/_regenerator2.default.mark(function _callee2() { | ||
var watcher, task; | ||
return _regenerator2.default.wrap(function _callee2$(_context2) { | ||
while (1) { | ||
switch (_context2.prev = _context2.next) { | ||
case 0: | ||
watcher = getWatcher(resolve, reject, key, effects[key], model, onError, onEffect); | ||
_context2.next = 3; | ||
return sagaEffects.fork(watcher); | ||
case 3: | ||
task = _context2.sent; | ||
_context2.next = 6; | ||
return sagaEffects.fork(_regenerator2.default.mark(function _callee() { | ||
return _regenerator2.default.wrap(function _callee$(_context) { | ||
while (1) { | ||
switch (_context.prev = _context.next) { | ||
case 0: | ||
_context.next = 2; | ||
return sagaEffects.take(model.namespace + '/@@CANCEL_EFFECTS'); | ||
case 3: | ||
task = _context2.sent; | ||
_context2.next = 6; | ||
return sagaEffects.fork( /*#__PURE__*/_regenerator2.default.mark(function _callee() { | ||
return _regenerator2.default.wrap(function _callee$(_context) { | ||
while (1) { | ||
switch (_context.prev = _context.next) { | ||
case 0: | ||
_context.next = 2; | ||
return sagaEffects.take(model.namespace + '/@@CANCEL_EFFECTS'); | ||
case 2: | ||
_context.next = 4; | ||
return sagaEffects.cancel(task); | ||
case 2: | ||
_context.next = 4; | ||
return sagaEffects.cancel(task); | ||
case 4: | ||
case 'end': | ||
return _context.stop(); | ||
case 4: | ||
case 'end': | ||
return _context.stop(); | ||
} | ||
} | ||
} | ||
}, _callee, this); | ||
})); | ||
}, _callee, this); | ||
})); | ||
case 6: | ||
case 'end': | ||
return _context2.stop(); | ||
case 6: | ||
case 'end': | ||
return _context2.stop(); | ||
} | ||
} | ||
} | ||
}, _callee2, _this); | ||
})(), 't2', 5); | ||
}, _callee2, _this); | ||
})(), 't2', 5); | ||
case 5: | ||
_context3.next = 1; | ||
break; | ||
case 5: | ||
_context3.next = 1; | ||
break; | ||
case 7: | ||
case 'end': | ||
return _context3.stop(); | ||
case 7: | ||
case 'end': | ||
return _context3.stop(); | ||
} | ||
} | ||
} | ||
}, _callee3, this); | ||
}); | ||
}, _callee3, this); | ||
}) | ||
); | ||
} | ||
function getWatcher(resolve, reject, key, _effect, model, onError, onEffect) { | ||
var _marked = [sagaWithCatch].map(_regenerator2.default.mark); | ||
var _marked = /*#__PURE__*/_regenerator2.default.mark(sagaWithCatch); | ||
@@ -193,3 +194,3 @@ var effect = _effect; | ||
} | ||
}, _marked[0], this, [[0, 12]]); | ||
}, _marked, this, [[0, 12]]); | ||
} | ||
@@ -203,49 +204,52 @@ | ||
case 'takeLatest': | ||
return _regenerator2.default.mark(function _callee4() { | ||
return _regenerator2.default.wrap(function _callee4$(_context5) { | ||
while (1) { | ||
switch (_context5.prev = _context5.next) { | ||
case 0: | ||
_context5.next = 2; | ||
return (0, _sagaHelpers.takeLatestHelper)(key, sagaWithOnEffect); | ||
return (/*#__PURE__*/_regenerator2.default.mark(function _callee4() { | ||
return _regenerator2.default.wrap(function _callee4$(_context5) { | ||
while (1) { | ||
switch (_context5.prev = _context5.next) { | ||
case 0: | ||
_context5.next = 2; | ||
return (0, _sagaHelpers.takeLatestHelper)(key, sagaWithOnEffect); | ||
case 2: | ||
case 'end': | ||
return _context5.stop(); | ||
case 2: | ||
case 'end': | ||
return _context5.stop(); | ||
} | ||
} | ||
} | ||
}, _callee4, this); | ||
}); | ||
}, _callee4, this); | ||
}) | ||
); | ||
case 'throttle': | ||
return _regenerator2.default.mark(function _callee5() { | ||
return _regenerator2.default.wrap(function _callee5$(_context6) { | ||
while (1) { | ||
switch (_context6.prev = _context6.next) { | ||
case 0: | ||
_context6.next = 2; | ||
return (0, _sagaHelpers.throttleHelper)(ms, key, sagaWithOnEffect); | ||
return (/*#__PURE__*/_regenerator2.default.mark(function _callee5() { | ||
return _regenerator2.default.wrap(function _callee5$(_context6) { | ||
while (1) { | ||
switch (_context6.prev = _context6.next) { | ||
case 0: | ||
_context6.next = 2; | ||
return (0, _sagaHelpers.throttleHelper)(ms, key, sagaWithOnEffect); | ||
case 2: | ||
case 'end': | ||
return _context6.stop(); | ||
case 2: | ||
case 'end': | ||
return _context6.stop(); | ||
} | ||
} | ||
} | ||
}, _callee5, this); | ||
}); | ||
}, _callee5, this); | ||
}) | ||
); | ||
default: | ||
return _regenerator2.default.mark(function _callee6() { | ||
return _regenerator2.default.wrap(function _callee6$(_context7) { | ||
while (1) { | ||
switch (_context7.prev = _context7.next) { | ||
case 0: | ||
_context7.next = 2; | ||
return (0, _sagaHelpers.takeEveryHelper)(key, sagaWithOnEffect); | ||
return (/*#__PURE__*/_regenerator2.default.mark(function _callee6() { | ||
return _regenerator2.default.wrap(function _callee6$(_context7) { | ||
while (1) { | ||
switch (_context7.prev = _context7.next) { | ||
case 0: | ||
_context7.next = 2; | ||
return (0, _sagaHelpers.takeEveryHelper)(key, sagaWithOnEffect); | ||
case 2: | ||
case 'end': | ||
return _context7.stop(); | ||
case 2: | ||
case 'end': | ||
return _context7.stop(); | ||
} | ||
} | ||
} | ||
}, _callee6, this); | ||
}); | ||
}, _callee6, this); | ||
}) | ||
); | ||
} | ||
@@ -252,0 +256,0 @@ } |
{ | ||
"name": "dva-core", | ||
"version": "0.1.3", | ||
"version": "0.2.0", | ||
"description": "The core lightweight library for dva, based on redux and redux-saga.", | ||
"repository": { | ||
"type": "git", | ||
"url": "https://github.com/dvajs/dva-core" | ||
"url": "https://github.com/dvajs/dva" | ||
}, | ||
"homepage": "https://github.com/dvajs/dva-core", | ||
"homepage": "https://github.com/dvajs/dva", | ||
"keywords": [ | ||
@@ -34,11 +34,4 @@ "dva", | ||
"lint": "ruban lint", | ||
"pub": "ruban pub", | ||
"precommit": "ruban lint-staged" | ||
"pub": "ruban pub" | ||
}, | ||
"lint-staged": { | ||
"*.js": [ | ||
"eslint --fix", | ||
"git add" | ||
] | ||
}, | ||
"dependencies": { | ||
@@ -45,0 +38,0 @@ "flatten": "^1.0.2", |
@@ -14,2 +14,1 @@ # dva-core | ||
MIT | ||
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
1685
60937
32
14