1 | (function webpackUniversalModuleDefinition(root, factory) {
|
2 | if(typeof exports === 'object' && typeof module === 'object')
|
3 | module.exports = factory(require("rxjs/Observable"), require("rxjs/Subject"), require("rxjs/operator/filter"), require("rxjs/operator/map"), require("rxjs/operator/switchMap"), require("rxjs/observable/from"), require("rxjs/observable/merge"), require("rxjs/observable/of"));
|
4 | else if(typeof define === 'function' && define.amd)
|
5 | define(["rxjs/Observable", "rxjs/Subject", "rxjs/operator/filter", "rxjs/operator/map", "rxjs/operator/switchMap", "rxjs/observable/from", "rxjs/observable/merge", "rxjs/observable/of"], factory);
|
6 | else if(typeof exports === 'object')
|
7 | exports["ReduxObservable"] = factory(require("rxjs/Observable"), require("rxjs/Subject"), require("rxjs/operator/filter"), require("rxjs/operator/map"), require("rxjs/operator/switchMap"), require("rxjs/observable/from"), require("rxjs/observable/merge"), require("rxjs/observable/of"));
|
8 | else
|
9 | root["ReduxObservable"] = factory(root["Rx"], root["Rx"], root["Rx"]["Observable"]["prototype"], root["Rx"]["Observable"]["prototype"], root["Rx"]["Observable"]["prototype"], root["Rx"]["Observable"], root["Rx"]["Observable"], root["Rx"]["Observable"]);
|
10 | })(this, function(__WEBPACK_EXTERNAL_MODULE_5__, __WEBPACK_EXTERNAL_MODULE_6__, __WEBPACK_EXTERNAL_MODULE_7__, __WEBPACK_EXTERNAL_MODULE_8__, __WEBPACK_EXTERNAL_MODULE_9__, __WEBPACK_EXTERNAL_MODULE_10__, __WEBPACK_EXTERNAL_MODULE_11__, __WEBPACK_EXTERNAL_MODULE_12__) {
|
11 | return (function(modules) {
|
12 |
|
13 | var installedModules = {};
|
14 |
|
15 |
|
16 | function __webpack_require__(moduleId) {
|
17 |
|
18 |
|
19 | if(installedModules[moduleId]) {
|
20 | return installedModules[moduleId].exports;
|
21 | }
|
22 |
|
23 | var module = installedModules[moduleId] = {
|
24 | i: moduleId,
|
25 | l: false,
|
26 | exports: {}
|
27 | };
|
28 |
|
29 |
|
30 | modules[moduleId].call(module.exports, module, module.exports, __webpack_require__);
|
31 |
|
32 |
|
33 | module.l = true;
|
34 |
|
35 |
|
36 | return module.exports;
|
37 | }
|
38 |
|
39 |
|
40 |
|
41 | __webpack_require__.m = modules;
|
42 |
|
43 |
|
44 | __webpack_require__.c = installedModules;
|
45 |
|
46 |
|
47 | __webpack_require__.i = function(value) { return value; };
|
48 |
|
49 |
|
50 | __webpack_require__.d = function(exports, name, getter) {
|
51 | if(!__webpack_require__.o(exports, name)) {
|
52 | Object.defineProperty(exports, name, {
|
53 | configurable: false,
|
54 | enumerable: true,
|
55 | get: getter
|
56 | /******/ });
|
57 | /******/ }
|
58 | /******/ };
|
59 | /******/
|
60 | /******/ // getDefaultExport function for compatibility with non-harmony modules
|
61 | /******/ __webpack_require__.n = function(module) {
|
62 | var getter = module && module.__esModule ?
|
63 | function getDefault() { return module['default']; } :
|
64 | function getModuleExports() { return module; };
|
65 | __webpack_require__.d(getter, 'a', getter);
|
66 | return getter;
|
67 | };
|
68 |
|
69 |
|
70 | __webpack_require__.o = function(object, property) { return Object.prototype.hasOwnProperty.call(object, property); };
|
71 |
|
72 |
|
73 | __webpack_require__.p = "";
|
74 |
|
75 |
|
76 | return __webpack_require__(__webpack_require__.s = 4);
|
77 | })
|
78 |
|
79 | ([
|
80 |
|
81 | (function(module, exports, __webpack_require__) {
|
82 |
|
83 | "use strict";
|
84 |
|
85 |
|
86 | Object.defineProperty(exports, "__esModule", {
|
87 | value: true
|
88 | });
|
89 | exports.ActionsObservable = undefined;
|
90 |
|
91 | var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
|
92 |
|
93 | var _Observable2 = __webpack_require__(5);
|
94 |
|
95 | var _of2 = __webpack_require__(12);
|
96 |
|
97 | var _from2 = __webpack_require__(10);
|
98 |
|
99 | var _filter = __webpack_require__(7);
|
100 |
|
101 | function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
|
102 |
|
103 | function _possibleConstructorReturn(self, call) { if (!self) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return call && (typeof call === "object" || typeof call === "function") ? call : self; }
|
104 |
|
105 | function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function, not " + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
|
106 |
|
107 | var ActionsObservable = exports.ActionsObservable = function (_Observable) {
|
108 | _inherits(ActionsObservable, _Observable);
|
109 |
|
110 | _createClass(ActionsObservable, null, [{
|
111 | key: 'of',
|
112 | value: function of() {
|
113 | return new this(_of2.of.apply(undefined, arguments));
|
114 | }
|
115 | }, {
|
116 | key: 'from',
|
117 | value: function from(actions, scheduler) {
|
118 | return new this((0, _from2.from)(actions, scheduler));
|
119 | }
|
120 | }]);
|
121 |
|
122 | function ActionsObservable(actionsSubject) {
|
123 | _classCallCheck(this, ActionsObservable);
|
124 |
|
125 | var _this = _possibleConstructorReturn(this, (ActionsObservable.__proto__ || Object.getPrototypeOf(ActionsObservable)).call(this));
|
126 |
|
127 | _this.source = actionsSubject;
|
128 | return _this;
|
129 | }
|
130 |
|
131 | _createClass(ActionsObservable, [{
|
132 | key: 'lift',
|
133 | value: function lift(operator) {
|
134 | var observable = new ActionsObservable(this);
|
135 | observable.operator = operator;
|
136 | return observable;
|
137 | }
|
138 | }, {
|
139 | key: 'ofType',
|
140 | value: function ofType() {
|
141 | for (var _len = arguments.length, keys = Array(_len), _key = 0; _key < _len; _key++) {
|
142 | keys[_key] = arguments[_key];
|
143 | }
|
144 |
|
145 | return _filter.filter.call(this, function (_ref) {
|
146 | var type = _ref.type;
|
147 |
|
148 | var len = keys.length;
|
149 | if (len === 1) {
|
150 | return type === keys[0];
|
151 | } else {
|
152 | for (var i = 0; i < len; i++) {
|
153 | if (keys[i] === type) {
|
154 | return true;
|
155 | }
|
156 | }
|
157 | }
|
158 | return false;
|
159 | });
|
160 | }
|
161 | }]);
|
162 |
|
163 | return ActionsObservable;
|
164 | }(_Observable2.Observable);
|
165 |
|
166 | }),
|
167 |
|
168 | (function(module, exports, __webpack_require__) {
|
169 |
|
170 | "use strict";
|
171 |
|
172 |
|
173 | Object.defineProperty(exports, "__esModule", {
|
174 | value: true
|
175 | });
|
176 | var EPIC_END = exports.EPIC_END = '@@redux-observable/EPIC_END';
|
177 |
|
178 | }),
|
179 |
|
180 | (function(module, exports, __webpack_require__) {
|
181 |
|
182 | "use strict";
|
183 |
|
184 |
|
185 | Object.defineProperty(exports, "__esModule", {
|
186 | value: true
|
187 | });
|
188 | exports.combineEpics = undefined;
|
189 |
|
190 | var _merge = __webpack_require__(11);
|
191 |
|
192 | 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); } }
|
193 |
|
194 |
|
195 |
|
196 |
|
197 | var combineEpics = exports.combineEpics = function combineEpics() {
|
198 | for (var _len = arguments.length, epics = Array(_len), _key = 0; _key < _len; _key++) {
|
199 | epics[_key] = arguments[_key];
|
200 | }
|
201 |
|
202 | return function () {
|
203 | for (var _len2 = arguments.length, args = Array(_len2), _key2 = 0; _key2 < _len2; _key2++) {
|
204 | args[_key2] = arguments[_key2];
|
205 | }
|
206 |
|
207 | return _merge.merge.apply(undefined, _toConsumableArray(epics.map(function (epic) {
|
208 | var output$ = epic.apply(undefined, args);
|
209 | if (!output$) {
|
210 | throw new TypeError('combineEpics: one of the provided Epics "' + (epic.name || '<anonymous>') + '" does not return a stream. Double check you\'re not missing a return statement!');
|
211 | }
|
212 | return output$;
|
213 | })));
|
214 | };
|
215 | };
|
216 |
|
217 | }),
|
218 |
|
219 | (function(module, exports, __webpack_require__) {
|
220 |
|
221 | "use strict";
|
222 |
|
223 |
|
224 | Object.defineProperty(exports, "__esModule", {
|
225 | value: true
|
226 | });
|
227 |
|
228 | var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
|
229 |
|
230 | exports.createEpicMiddleware = createEpicMiddleware;
|
231 |
|
232 | var _Subject = __webpack_require__(6);
|
233 |
|
234 | var _map = __webpack_require__(8);
|
235 |
|
236 | var _switchMap = __webpack_require__(9);
|
237 |
|
238 | var _ActionsObservable = __webpack_require__(0);
|
239 |
|
240 | var _EPIC_END = __webpack_require__(1);
|
241 |
|
242 | var defaultAdapter = {
|
243 | input: function input(action$) {
|
244 | return action$;
|
245 | },
|
246 | output: function output(action$) {
|
247 | return action$;
|
248 | }
|
249 | };
|
250 |
|
251 | var defaultOptions = {
|
252 | adapter: defaultAdapter
|
253 | };
|
254 |
|
255 | function createEpicMiddleware(epic) {
|
256 | var options = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : defaultOptions;
|
257 |
|
258 | if (typeof epic !== 'function') {
|
259 | throw new TypeError('You must provide a root Epic to createEpicMiddleware');
|
260 | }
|
261 |
|
262 |
|
263 |
|
264 | options = _extends({}, defaultOptions, options);
|
265 | var input$ = new _Subject.Subject();
|
266 | var action$ = options.adapter.input(new _ActionsObservable.ActionsObservable(input$));
|
267 | var epic$ = new _Subject.Subject();
|
268 | var store = void 0;
|
269 |
|
270 | var epicMiddleware = function epicMiddleware(_store) {
|
271 | store = _store;
|
272 |
|
273 | return function (next) {
|
274 | var _context;
|
275 |
|
276 | (_context = _map.map.call(epic$, function (epic) {
|
277 | var output$ = 'dependencies' in options ? epic(action$, store, options.dependencies) : epic(action$, store);
|
278 |
|
279 | if (!output$) {
|
280 | throw new TypeError('Your root Epic "' + (epic.name || '<anonymous>') + '" does not return a stream. Double check you\'re not missing a return statement!');
|
281 | }
|
282 |
|
283 | return output$;
|
284 | }), _switchMap.switchMap).call(_context, function (output$) {
|
285 | return options.adapter.output(output$);
|
286 | }).subscribe(store.dispatch);
|
287 |
|
288 |
|
289 | epic$.next(epic);
|
290 |
|
291 | return function (action) {
|
292 | var result = next(action);
|
293 | input$.next(action);
|
294 | return result;
|
295 | };
|
296 | };
|
297 | };
|
298 |
|
299 | epicMiddleware.replaceEpic = function (epic) {
|
300 |
|
301 |
|
302 | store.dispatch({ type: _EPIC_END.EPIC_END });
|
303 |
|
304 |
|
305 | epic$.next(epic);
|
306 | };
|
307 |
|
308 | return epicMiddleware;
|
309 | }
|
310 |
|
311 | }),
|
312 |
|
313 | (function(module, exports, __webpack_require__) {
|
314 |
|
315 | "use strict";
|
316 |
|
317 |
|
318 | Object.defineProperty(exports, "__esModule", {
|
319 | value: true
|
320 | });
|
321 |
|
322 | var _createEpicMiddleware = __webpack_require__(3);
|
323 |
|
324 | Object.defineProperty(exports, 'createEpicMiddleware', {
|
325 | enumerable: true,
|
326 | get: function get() {
|
327 | return _createEpicMiddleware.createEpicMiddleware;
|
328 | }
|
329 | });
|
330 |
|
331 | var _ActionsObservable = __webpack_require__(0);
|
332 |
|
333 | Object.defineProperty(exports, 'ActionsObservable', {
|
334 | enumerable: true,
|
335 | get: function get() {
|
336 | return _ActionsObservable.ActionsObservable;
|
337 | }
|
338 | });
|
339 |
|
340 | var _combineEpics = __webpack_require__(2);
|
341 |
|
342 | Object.defineProperty(exports, 'combineEpics', {
|
343 | enumerable: true,
|
344 | get: function get() {
|
345 | return _combineEpics.combineEpics;
|
346 | }
|
347 | });
|
348 |
|
349 | var _EPIC_END = __webpack_require__(1);
|
350 |
|
351 | Object.defineProperty(exports, 'EPIC_END', {
|
352 | enumerable: true,
|
353 | get: function get() {
|
354 | return _EPIC_END.EPIC_END;
|
355 | }
|
356 | });
|
357 |
|
358 | }),
|
359 |
|
360 | (function(module, exports) {
|
361 |
|
362 | module.exports = __WEBPACK_EXTERNAL_MODULE_5__;
|
363 |
|
364 | }),
|
365 |
|
366 | (function(module, exports) {
|
367 |
|
368 | module.exports = __WEBPACK_EXTERNAL_MODULE_6__;
|
369 |
|
370 | }),
|
371 |
|
372 | (function(module, exports) {
|
373 |
|
374 | module.exports = __WEBPACK_EXTERNAL_MODULE_7__;
|
375 |
|
376 | }),
|
377 |
|
378 | (function(module, exports) {
|
379 |
|
380 | module.exports = __WEBPACK_EXTERNAL_MODULE_8__;
|
381 |
|
382 | }),
|
383 |
|
384 | (function(module, exports) {
|
385 |
|
386 | module.exports = __WEBPACK_EXTERNAL_MODULE_9__;
|
387 |
|
388 | }),
|
389 |
|
390 | (function(module, exports) {
|
391 |
|
392 | module.exports = __WEBPACK_EXTERNAL_MODULE_10__;
|
393 |
|
394 | }),
|
395 |
|
396 | (function(module, exports) {
|
397 |
|
398 | module.exports = __WEBPACK_EXTERNAL_MODULE_11__;
|
399 |
|
400 | }),
|
401 |
|
402 | (function(module, exports) {
|
403 |
|
404 | module.exports = __WEBPACK_EXTERNAL_MODULE_12__;
|
405 |
|
406 | })
|
407 | ]);
|
408 | }); |
\ | No newline at end of file |