Нема описа

redux-routine.js 25KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929
  1. this["wp"] = this["wp"] || {}; this["wp"]["reduxRoutine"] =
  2. /******/ (function(modules) { // webpackBootstrap
  3. /******/ // The module cache
  4. /******/ var installedModules = {};
  5. /******/
  6. /******/ // The require function
  7. /******/ function __webpack_require__(moduleId) {
  8. /******/
  9. /******/ // Check if module is in cache
  10. /******/ if(installedModules[moduleId]) {
  11. /******/ return installedModules[moduleId].exports;
  12. /******/ }
  13. /******/ // Create a new module (and put it into the cache)
  14. /******/ var module = installedModules[moduleId] = {
  15. /******/ i: moduleId,
  16. /******/ l: false,
  17. /******/ exports: {}
  18. /******/ };
  19. /******/
  20. /******/ // Execute the module function
  21. /******/ modules[moduleId].call(module.exports, module, module.exports, __webpack_require__);
  22. /******/
  23. /******/ // Flag the module as loaded
  24. /******/ module.l = true;
  25. /******/
  26. /******/ // Return the exports of the module
  27. /******/ return module.exports;
  28. /******/ }
  29. /******/
  30. /******/
  31. /******/ // expose the modules object (__webpack_modules__)
  32. /******/ __webpack_require__.m = modules;
  33. /******/
  34. /******/ // expose the module cache
  35. /******/ __webpack_require__.c = installedModules;
  36. /******/
  37. /******/ // define getter function for harmony exports
  38. /******/ __webpack_require__.d = function(exports, name, getter) {
  39. /******/ if(!__webpack_require__.o(exports, name)) {
  40. /******/ Object.defineProperty(exports, name, { enumerable: true, get: getter });
  41. /******/ }
  42. /******/ };
  43. /******/
  44. /******/ // define __esModule on exports
  45. /******/ __webpack_require__.r = function(exports) {
  46. /******/ if(typeof Symbol !== 'undefined' && Symbol.toStringTag) {
  47. /******/ Object.defineProperty(exports, Symbol.toStringTag, { value: 'Module' });
  48. /******/ }
  49. /******/ Object.defineProperty(exports, '__esModule', { value: true });
  50. /******/ };
  51. /******/
  52. /******/ // create a fake namespace object
  53. /******/ // mode & 1: value is a module id, require it
  54. /******/ // mode & 2: merge all properties of value into the ns
  55. /******/ // mode & 4: return value when already ns object
  56. /******/ // mode & 8|1: behave like require
  57. /******/ __webpack_require__.t = function(value, mode) {
  58. /******/ if(mode & 1) value = __webpack_require__(value);
  59. /******/ if(mode & 8) return value;
  60. /******/ if((mode & 4) && typeof value === 'object' && value && value.__esModule) return value;
  61. /******/ var ns = Object.create(null);
  62. /******/ __webpack_require__.r(ns);
  63. /******/ Object.defineProperty(ns, 'default', { enumerable: true, value: value });
  64. /******/ if(mode & 2 && typeof value != 'string') for(var key in value) __webpack_require__.d(ns, key, function(key) { return value[key]; }.bind(null, key));
  65. /******/ return ns;
  66. /******/ };
  67. /******/
  68. /******/ // getDefaultExport function for compatibility with non-harmony modules
  69. /******/ __webpack_require__.n = function(module) {
  70. /******/ var getter = module && module.__esModule ?
  71. /******/ function getDefault() { return module['default']; } :
  72. /******/ function getModuleExports() { return module; };
  73. /******/ __webpack_require__.d(getter, 'a', getter);
  74. /******/ return getter;
  75. /******/ };
  76. /******/
  77. /******/ // Object.prototype.hasOwnProperty.call
  78. /******/ __webpack_require__.o = function(object, property) { return Object.prototype.hasOwnProperty.call(object, property); };
  79. /******/
  80. /******/ // __webpack_public_path__
  81. /******/ __webpack_require__.p = "";
  82. /******/
  83. /******/
  84. /******/ // Load entry module and return exports
  85. /******/ return __webpack_require__(__webpack_require__.s = "+ekt");
  86. /******/ })
  87. /************************************************************************/
  88. /******/ ({
  89. /***/ "+ekt":
  90. /***/ (function(module, __webpack_exports__, __webpack_require__) {
  91. "use strict";
  92. // ESM COMPAT FLAG
  93. __webpack_require__.r(__webpack_exports__);
  94. // EXPORTS
  95. __webpack_require__.d(__webpack_exports__, "default", function() { return /* binding */ createMiddleware; });
  96. // CONCATENATED MODULE: ./node_modules/@wordpress/redux-routine/build-module/is-generator.js
  97. /**
  98. * Returns true if the given object is a generator, or false otherwise.
  99. *
  100. * @see https://www.ecma-international.org/ecma-262/6.0/#sec-generator-objects
  101. *
  102. * @param {*} object Object to test.
  103. *
  104. * @return {boolean} Whether object is a generator.
  105. */
  106. function isGenerator(object) {
  107. // Check that iterator (next) and iterable (Symbol.iterator) interfaces are satisfied.
  108. // These checks seem to be compatible with several generator helpers as well as the native implementation.
  109. return !!object && typeof object[Symbol.iterator] === 'function' && typeof object.next === 'function';
  110. }
  111. // EXTERNAL MODULE: ./node_modules/rungen/dist/index.js
  112. var dist = __webpack_require__("hnoU");
  113. // EXTERNAL MODULE: external "lodash"
  114. var external_lodash_ = __webpack_require__("YLtl");
  115. // EXTERNAL MODULE: ./node_modules/is-promise/index.js
  116. var is_promise = __webpack_require__("JlUD");
  117. var is_promise_default = /*#__PURE__*/__webpack_require__.n(is_promise);
  118. // CONCATENATED MODULE: ./node_modules/@wordpress/redux-routine/build-module/is-action.js
  119. /**
  120. * External dependencies
  121. */
  122. /**
  123. * Returns true if the given object quacks like an action.
  124. *
  125. * @param {*} object Object to test
  126. *
  127. * @return {boolean} Whether object is an action.
  128. */
  129. function isAction(object) {
  130. return Object(external_lodash_["isPlainObject"])(object) && Object(external_lodash_["isString"])(object.type);
  131. }
  132. /**
  133. * Returns true if the given object quacks like an action and has a specific
  134. * action type
  135. *
  136. * @param {*} object Object to test
  137. * @param {string} expectedType The expected type for the action.
  138. *
  139. * @return {boolean} Whether object is an action and is of specific type.
  140. */
  141. function isActionOfType(object, expectedType) {
  142. return isAction(object) && object.type === expectedType;
  143. }
  144. // CONCATENATED MODULE: ./node_modules/@wordpress/redux-routine/build-module/runtime.js
  145. /**
  146. * External dependencies
  147. */
  148. /**
  149. * Internal dependencies
  150. */
  151. /**
  152. * Create a co-routine runtime.
  153. *
  154. * @param {Object} controls Object of control handlers.
  155. * @param {Function} dispatch Unhandled action dispatch.
  156. *
  157. * @return {Function} co-routine runtime
  158. */
  159. function createRuntime(controls = {}, dispatch) {
  160. const rungenControls = Object(external_lodash_["map"])(controls, (control, actionType) => (value, next, iterate, yieldNext, yieldError) => {
  161. if (!isActionOfType(value, actionType)) {
  162. return false;
  163. }
  164. const routine = control(value);
  165. if (is_promise_default()(routine)) {
  166. // Async control routine awaits resolution.
  167. routine.then(yieldNext, yieldError);
  168. } else {
  169. yieldNext(routine);
  170. }
  171. return true;
  172. });
  173. const unhandledActionControl = (value, next) => {
  174. if (!isAction(value)) {
  175. return false;
  176. }
  177. dispatch(value);
  178. next();
  179. return true;
  180. };
  181. rungenControls.push(unhandledActionControl);
  182. const rungenRuntime = Object(dist["create"])(rungenControls);
  183. return action => new Promise((resolve, reject) => rungenRuntime(action, result => {
  184. if (isAction(result)) {
  185. dispatch(result);
  186. }
  187. resolve(result);
  188. }, reject));
  189. }
  190. // CONCATENATED MODULE: ./node_modules/@wordpress/redux-routine/build-module/index.js
  191. /**
  192. * Internal dependencies
  193. */
  194. /**
  195. * Creates a Redux middleware, given an object of controls where each key is an
  196. * action type for which to act upon, the value a function which returns either
  197. * a promise which is to resolve when evaluation of the action should continue,
  198. * or a value. The value or resolved promise value is assigned on the return
  199. * value of the yield assignment. If the control handler returns undefined, the
  200. * execution is not continued.
  201. *
  202. * @param {Object} controls Object of control handlers.
  203. *
  204. * @return {Function} Co-routine runtime
  205. */
  206. function createMiddleware(controls = {}) {
  207. return store => {
  208. const runtime = createRuntime(controls, store.dispatch);
  209. return next => action => {
  210. if (!isGenerator(action)) {
  211. return next(action);
  212. }
  213. return runtime(action);
  214. };
  215. };
  216. }
  217. /***/ }),
  218. /***/ "Hkfj":
  219. /***/ (function(module, exports, __webpack_require__) {
  220. "use strict";
  221. Object.defineProperty(exports, "__esModule", {
  222. value: true
  223. });
  224. var createDispatcher = function createDispatcher() {
  225. var listeners = [];
  226. return {
  227. subscribe: function subscribe(listener) {
  228. listeners.push(listener);
  229. return function () {
  230. listeners = listeners.filter(function (l) {
  231. return l !== listener;
  232. });
  233. };
  234. },
  235. dispatch: function dispatch(action) {
  236. listeners.slice().forEach(function (listener) {
  237. return listener(action);
  238. });
  239. }
  240. };
  241. };
  242. exports.default = createDispatcher;
  243. /***/ }),
  244. /***/ "JlUD":
  245. /***/ (function(module, exports) {
  246. module.exports = isPromise;
  247. module.exports.default = isPromise;
  248. function isPromise(obj) {
  249. return !!obj && (typeof obj === 'object' || typeof obj === 'function') && typeof obj.then === 'function';
  250. }
  251. /***/ }),
  252. /***/ "PERq":
  253. /***/ (function(module, exports, __webpack_require__) {
  254. "use strict";
  255. Object.defineProperty(exports, "__esModule", {
  256. value: true
  257. });
  258. exports.cps = exports.call = undefined;
  259. var _is = __webpack_require__("qmpp");
  260. var _is2 = _interopRequireDefault(_is);
  261. function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
  262. function _toConsumableArray(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } else { return Array.from(arr); } }
  263. var call = exports.call = function call(value, next, rungen, yieldNext, raiseNext) {
  264. if (!_is2.default.call(value)) return false;
  265. try {
  266. next(value.func.apply(value.context, value.args));
  267. } catch (err) {
  268. raiseNext(err);
  269. }
  270. return true;
  271. };
  272. var cps = exports.cps = function cps(value, next, rungen, yieldNext, raiseNext) {
  273. var _value$func;
  274. if (!_is2.default.cps(value)) return false;
  275. (_value$func = value.func).call.apply(_value$func, [null].concat(_toConsumableArray(value.args), [function (err, result) {
  276. if (err) raiseNext(err);else next(result);
  277. }]));
  278. return true;
  279. };
  280. exports.default = [call, cps];
  281. /***/ }),
  282. /***/ "YLtl":
  283. /***/ (function(module, exports) {
  284. (function() { module.exports = window["lodash"]; }());
  285. /***/ }),
  286. /***/ "e6BM":
  287. /***/ (function(module, exports, __webpack_require__) {
  288. "use strict";
  289. Object.defineProperty(exports, "__esModule", {
  290. value: true
  291. });
  292. exports.createChannel = exports.subscribe = exports.cps = exports.apply = exports.call = exports.invoke = exports.delay = exports.race = exports.join = exports.fork = exports.error = exports.all = undefined;
  293. var _keys = __webpack_require__("tGEh");
  294. var _keys2 = _interopRequireDefault(_keys);
  295. function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
  296. var all = exports.all = function all(value) {
  297. return {
  298. type: _keys2.default.all,
  299. value: value
  300. };
  301. };
  302. var error = exports.error = function error(err) {
  303. return {
  304. type: _keys2.default.error,
  305. error: err
  306. };
  307. };
  308. var fork = exports.fork = function fork(iterator) {
  309. for (var _len = arguments.length, args = Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
  310. args[_key - 1] = arguments[_key];
  311. }
  312. return {
  313. type: _keys2.default.fork,
  314. iterator: iterator,
  315. args: args
  316. };
  317. };
  318. var join = exports.join = function join(task) {
  319. return {
  320. type: _keys2.default.join,
  321. task: task
  322. };
  323. };
  324. var race = exports.race = function race(competitors) {
  325. return {
  326. type: _keys2.default.race,
  327. competitors: competitors
  328. };
  329. };
  330. var delay = exports.delay = function delay(timeout) {
  331. return new Promise(function (resolve) {
  332. setTimeout(function () {
  333. return resolve(true);
  334. }, timeout);
  335. });
  336. };
  337. var invoke = exports.invoke = function invoke(func) {
  338. for (var _len2 = arguments.length, args = Array(_len2 > 1 ? _len2 - 1 : 0), _key2 = 1; _key2 < _len2; _key2++) {
  339. args[_key2 - 1] = arguments[_key2];
  340. }
  341. return {
  342. type: _keys2.default.call,
  343. func: func,
  344. context: null,
  345. args: args
  346. };
  347. };
  348. var call = exports.call = function call(func, context) {
  349. for (var _len3 = arguments.length, args = Array(_len3 > 2 ? _len3 - 2 : 0), _key3 = 2; _key3 < _len3; _key3++) {
  350. args[_key3 - 2] = arguments[_key3];
  351. }
  352. return {
  353. type: _keys2.default.call,
  354. func: func,
  355. context: context,
  356. args: args
  357. };
  358. };
  359. var apply = exports.apply = function apply(func, context, args) {
  360. return {
  361. type: _keys2.default.call,
  362. func: func,
  363. context: context,
  364. args: args
  365. };
  366. };
  367. var cps = exports.cps = function cps(func) {
  368. for (var _len4 = arguments.length, args = Array(_len4 > 1 ? _len4 - 1 : 0), _key4 = 1; _key4 < _len4; _key4++) {
  369. args[_key4 - 1] = arguments[_key4];
  370. }
  371. return {
  372. type: _keys2.default.cps,
  373. func: func,
  374. args: args
  375. };
  376. };
  377. var subscribe = exports.subscribe = function subscribe(channel) {
  378. return {
  379. type: _keys2.default.subscribe,
  380. channel: channel
  381. };
  382. };
  383. var createChannel = exports.createChannel = function createChannel(callback) {
  384. var listeners = [];
  385. var subscribe = function subscribe(l) {
  386. listeners.push(l);
  387. return function () {
  388. return listeners.splice(listeners.indexOf(l), 1);
  389. };
  390. };
  391. var next = function next(val) {
  392. return listeners.forEach(function (l) {
  393. return l(val);
  394. });
  395. };
  396. callback(next);
  397. return {
  398. subscribe: subscribe
  399. };
  400. };
  401. /***/ }),
  402. /***/ "hecb":
  403. /***/ (function(module, exports, __webpack_require__) {
  404. "use strict";
  405. Object.defineProperty(exports, "__esModule", {
  406. value: true
  407. });
  408. exports.race = exports.join = exports.fork = exports.promise = undefined;
  409. var _is = __webpack_require__("qmpp");
  410. var _is2 = _interopRequireDefault(_is);
  411. var _helpers = __webpack_require__("e6BM");
  412. var _dispatcher = __webpack_require__("Hkfj");
  413. var _dispatcher2 = _interopRequireDefault(_dispatcher);
  414. function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
  415. var promise = exports.promise = function promise(value, next, rungen, yieldNext, raiseNext) {
  416. if (!_is2.default.promise(value)) return false;
  417. value.then(next, raiseNext);
  418. return true;
  419. };
  420. var forkedTasks = new Map();
  421. var fork = exports.fork = function fork(value, next, rungen) {
  422. if (!_is2.default.fork(value)) return false;
  423. var task = Symbol('fork');
  424. var dispatcher = (0, _dispatcher2.default)();
  425. forkedTasks.set(task, dispatcher);
  426. rungen(value.iterator.apply(null, value.args), function (result) {
  427. return dispatcher.dispatch(result);
  428. }, function (err) {
  429. return dispatcher.dispatch((0, _helpers.error)(err));
  430. });
  431. var unsubscribe = dispatcher.subscribe(function () {
  432. unsubscribe();
  433. forkedTasks.delete(task);
  434. });
  435. next(task);
  436. return true;
  437. };
  438. var join = exports.join = function join(value, next, rungen, yieldNext, raiseNext) {
  439. if (!_is2.default.join(value)) return false;
  440. var dispatcher = forkedTasks.get(value.task);
  441. if (!dispatcher) {
  442. raiseNext('join error : task not found');
  443. } else {
  444. (function () {
  445. var unsubscribe = dispatcher.subscribe(function (result) {
  446. unsubscribe();
  447. next(result);
  448. });
  449. })();
  450. }
  451. return true;
  452. };
  453. var race = exports.race = function race(value, next, rungen, yieldNext, raiseNext) {
  454. if (!_is2.default.race(value)) return false;
  455. var finished = false;
  456. var success = function success(result, k, v) {
  457. if (finished) return;
  458. finished = true;
  459. result[k] = v;
  460. next(result);
  461. };
  462. var fail = function fail(err) {
  463. if (finished) return;
  464. raiseNext(err);
  465. };
  466. if (_is2.default.array(value.competitors)) {
  467. (function () {
  468. var result = value.competitors.map(function () {
  469. return false;
  470. });
  471. value.competitors.forEach(function (competitor, index) {
  472. rungen(competitor, function (output) {
  473. return success(result, index, output);
  474. }, fail);
  475. });
  476. })();
  477. } else {
  478. (function () {
  479. var result = Object.keys(value.competitors).reduce(function (p, c) {
  480. p[c] = false;
  481. return p;
  482. }, {});
  483. Object.keys(value.competitors).forEach(function (index) {
  484. rungen(value.competitors[index], function (output) {
  485. return success(result, index, output);
  486. }, fail);
  487. });
  488. })();
  489. }
  490. return true;
  491. };
  492. var subscribe = function subscribe(value, next) {
  493. if (!_is2.default.subscribe(value)) return false;
  494. if (!_is2.default.channel(value.channel)) {
  495. throw new Error('the first argument of "subscribe" must be a valid channel');
  496. }
  497. var unsubscribe = value.channel.subscribe(function (ret) {
  498. unsubscribe && unsubscribe();
  499. next(ret);
  500. });
  501. return true;
  502. };
  503. exports.default = [promise, fork, join, race, subscribe];
  504. /***/ }),
  505. /***/ "hnoU":
  506. /***/ (function(module, exports, __webpack_require__) {
  507. "use strict";
  508. Object.defineProperty(exports, "__esModule", {
  509. value: true
  510. });
  511. exports.wrapControls = exports.asyncControls = exports.create = undefined;
  512. var _helpers = __webpack_require__("e6BM");
  513. Object.keys(_helpers).forEach(function (key) {
  514. if (key === "default") return;
  515. Object.defineProperty(exports, key, {
  516. enumerable: true,
  517. get: function get() {
  518. return _helpers[key];
  519. }
  520. });
  521. });
  522. var _create = __webpack_require__("vsQm");
  523. var _create2 = _interopRequireDefault(_create);
  524. var _async = __webpack_require__("hecb");
  525. var _async2 = _interopRequireDefault(_async);
  526. var _wrap = __webpack_require__("PERq");
  527. var _wrap2 = _interopRequireDefault(_wrap);
  528. function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
  529. exports.create = _create2.default;
  530. exports.asyncControls = _async2.default;
  531. exports.wrapControls = _wrap2.default;
  532. /***/ }),
  533. /***/ "k4FQ":
  534. /***/ (function(module, exports, __webpack_require__) {
  535. "use strict";
  536. Object.defineProperty(exports, "__esModule", {
  537. value: true
  538. });
  539. exports.iterator = exports.array = exports.object = exports.error = exports.any = undefined;
  540. var _is = __webpack_require__("qmpp");
  541. var _is2 = _interopRequireDefault(_is);
  542. function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
  543. var any = exports.any = function any(value, next, rungen, yieldNext) {
  544. yieldNext(value);
  545. return true;
  546. };
  547. var error = exports.error = function error(value, next, rungen, yieldNext, raiseNext) {
  548. if (!_is2.default.error(value)) return false;
  549. raiseNext(value.error);
  550. return true;
  551. };
  552. var object = exports.object = function object(value, next, rungen, yieldNext, raiseNext) {
  553. if (!_is2.default.all(value) || !_is2.default.obj(value.value)) return false;
  554. var result = {};
  555. var keys = Object.keys(value.value);
  556. var count = 0;
  557. var hasError = false;
  558. var gotResultSuccess = function gotResultSuccess(key, ret) {
  559. if (hasError) return;
  560. result[key] = ret;
  561. count++;
  562. if (count === keys.length) {
  563. yieldNext(result);
  564. }
  565. };
  566. var gotResultError = function gotResultError(key, error) {
  567. if (hasError) return;
  568. hasError = true;
  569. raiseNext(error);
  570. };
  571. keys.map(function (key) {
  572. rungen(value.value[key], function (ret) {
  573. return gotResultSuccess(key, ret);
  574. }, function (err) {
  575. return gotResultError(key, err);
  576. });
  577. });
  578. return true;
  579. };
  580. var array = exports.array = function array(value, next, rungen, yieldNext, raiseNext) {
  581. if (!_is2.default.all(value) || !_is2.default.array(value.value)) return false;
  582. var result = [];
  583. var count = 0;
  584. var hasError = false;
  585. var gotResultSuccess = function gotResultSuccess(key, ret) {
  586. if (hasError) return;
  587. result[key] = ret;
  588. count++;
  589. if (count === value.value.length) {
  590. yieldNext(result);
  591. }
  592. };
  593. var gotResultError = function gotResultError(key, error) {
  594. if (hasError) return;
  595. hasError = true;
  596. raiseNext(error);
  597. };
  598. value.value.map(function (v, key) {
  599. rungen(v, function (ret) {
  600. return gotResultSuccess(key, ret);
  601. }, function (err) {
  602. return gotResultError(key, err);
  603. });
  604. });
  605. return true;
  606. };
  607. var iterator = exports.iterator = function iterator(value, next, rungen, yieldNext, raiseNext) {
  608. if (!_is2.default.iterator(value)) return false;
  609. rungen(value, next, raiseNext);
  610. return true;
  611. };
  612. exports.default = [error, iterator, array, object, any];
  613. /***/ }),
  614. /***/ "qmpp":
  615. /***/ (function(module, exports, __webpack_require__) {
  616. "use strict";
  617. Object.defineProperty(exports, "__esModule", {
  618. value: true
  619. });
  620. var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol ? "symbol" : typeof obj; };
  621. var _keys = __webpack_require__("tGEh");
  622. var _keys2 = _interopRequireDefault(_keys);
  623. function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
  624. var is = {
  625. obj: function obj(value) {
  626. return (typeof value === 'undefined' ? 'undefined' : _typeof(value)) === 'object' && !!value;
  627. },
  628. all: function all(value) {
  629. return is.obj(value) && value.type === _keys2.default.all;
  630. },
  631. error: function error(value) {
  632. return is.obj(value) && value.type === _keys2.default.error;
  633. },
  634. array: Array.isArray,
  635. func: function func(value) {
  636. return typeof value === 'function';
  637. },
  638. promise: function promise(value) {
  639. return value && is.func(value.then);
  640. },
  641. iterator: function iterator(value) {
  642. return value && is.func(value.next) && is.func(value.throw);
  643. },
  644. fork: function fork(value) {
  645. return is.obj(value) && value.type === _keys2.default.fork;
  646. },
  647. join: function join(value) {
  648. return is.obj(value) && value.type === _keys2.default.join;
  649. },
  650. race: function race(value) {
  651. return is.obj(value) && value.type === _keys2.default.race;
  652. },
  653. call: function call(value) {
  654. return is.obj(value) && value.type === _keys2.default.call;
  655. },
  656. cps: function cps(value) {
  657. return is.obj(value) && value.type === _keys2.default.cps;
  658. },
  659. subscribe: function subscribe(value) {
  660. return is.obj(value) && value.type === _keys2.default.subscribe;
  661. },
  662. channel: function channel(value) {
  663. return is.obj(value) && is.func(value.subscribe);
  664. }
  665. };
  666. exports.default = is;
  667. /***/ }),
  668. /***/ "tGEh":
  669. /***/ (function(module, exports, __webpack_require__) {
  670. "use strict";
  671. Object.defineProperty(exports, "__esModule", {
  672. value: true
  673. });
  674. var keys = {
  675. all: Symbol('all'),
  676. error: Symbol('error'),
  677. fork: Symbol('fork'),
  678. join: Symbol('join'),
  679. race: Symbol('race'),
  680. call: Symbol('call'),
  681. cps: Symbol('cps'),
  682. subscribe: Symbol('subscribe')
  683. };
  684. exports.default = keys;
  685. /***/ }),
  686. /***/ "vsQm":
  687. /***/ (function(module, exports, __webpack_require__) {
  688. "use strict";
  689. Object.defineProperty(exports, "__esModule", {
  690. value: true
  691. });
  692. var _builtin = __webpack_require__("k4FQ");
  693. var _builtin2 = _interopRequireDefault(_builtin);
  694. var _is = __webpack_require__("qmpp");
  695. var _is2 = _interopRequireDefault(_is);
  696. function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
  697. function _toConsumableArray(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } else { return Array.from(arr); } }
  698. var create = function create() {
  699. var userControls = arguments.length <= 0 || arguments[0] === undefined ? [] : arguments[0];
  700. var controls = [].concat(_toConsumableArray(userControls), _toConsumableArray(_builtin2.default));
  701. var runtime = function runtime(input) {
  702. var success = arguments.length <= 1 || arguments[1] === undefined ? function () {} : arguments[1];
  703. var error = arguments.length <= 2 || arguments[2] === undefined ? function () {} : arguments[2];
  704. var iterate = function iterate(gen) {
  705. var yieldValue = function yieldValue(isError) {
  706. return function (ret) {
  707. try {
  708. var _ref = isError ? gen.throw(ret) : gen.next(ret);
  709. var value = _ref.value;
  710. var done = _ref.done;
  711. if (done) return success(value);
  712. next(value);
  713. } catch (e) {
  714. return error(e);
  715. }
  716. };
  717. };
  718. var next = function next(ret) {
  719. controls.some(function (control) {
  720. return control(ret, next, runtime, yieldValue(false), yieldValue(true));
  721. });
  722. };
  723. yieldValue(false)();
  724. };
  725. var iterator = _is2.default.iterator(input) ? input : regeneratorRuntime.mark(function _callee() {
  726. return regeneratorRuntime.wrap(function _callee$(_context) {
  727. while (1) {
  728. switch (_context.prev = _context.next) {
  729. case 0:
  730. _context.next = 2;
  731. return input;
  732. case 2:
  733. return _context.abrupt('return', _context.sent);
  734. case 3:
  735. case 'end':
  736. return _context.stop();
  737. }
  738. }
  739. }, _callee, this);
  740. })();
  741. iterate(iterator, success, error);
  742. };
  743. return runtime;
  744. };
  745. exports.default = create;
  746. /***/ })
  747. /******/ })["default"];