You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
89 lines
3.4 KiB
89 lines
3.4 KiB
'use strict';
|
|
|
|
exports.__esModule = true;
|
|
exports.default = sagaMiddlewareFactory;
|
|
|
|
var _utils = /*#__PURE__*/require('./utils');
|
|
|
|
var _channel = /*#__PURE__*/require('./channel');
|
|
|
|
var _runSaga = /*#__PURE__*/require('./runSaga');
|
|
|
|
function _objectWithoutProperties(obj, keys) { var target = {}; for (var i in obj) { if (keys.indexOf(i) >= 0) continue; if (!Object.prototype.hasOwnProperty.call(obj, i)) continue; target[i] = obj[i]; } return target; }
|
|
|
|
function sagaMiddlewareFactory() {
|
|
var _ref = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
|
|
|
|
var _ref$context = _ref.context,
|
|
context = _ref$context === undefined ? {} : _ref$context,
|
|
options = _objectWithoutProperties(_ref, ['context']);
|
|
|
|
var sagaMonitor = options.sagaMonitor,
|
|
logger = options.logger,
|
|
onError = options.onError;
|
|
|
|
|
|
if (_utils.is.func(options)) {
|
|
if (process.env.NODE_ENV === 'production') {
|
|
throw new Error('Saga middleware no longer accept Generator functions. Use sagaMiddleware.run instead');
|
|
} else {
|
|
throw new Error('You passed a function to the Saga middleware. You are likely trying to start a Saga by directly passing it to the middleware. This is no longer possible starting from 0.10.0. To run a Saga, you must do it dynamically AFTER mounting the middleware into the store.\n Example:\n import createSagaMiddleware from \'redux-saga\'\n ... other imports\n\n const sagaMiddleware = createSagaMiddleware()\n const store = createStore(reducer, applyMiddleware(sagaMiddleware))\n sagaMiddleware.run(saga, ...args)\n ');
|
|
}
|
|
}
|
|
|
|
if (logger && !_utils.is.func(logger)) {
|
|
throw new Error('`options.logger` passed to the Saga middleware is not a function!');
|
|
}
|
|
|
|
if (process.env.NODE_ENV === 'development' && options.onerror) {
|
|
throw new Error('`options.onerror` was removed. Use `options.onError` instead.');
|
|
}
|
|
|
|
if (onError && !_utils.is.func(onError)) {
|
|
throw new Error('`options.onError` passed to the Saga middleware is not a function!');
|
|
}
|
|
|
|
if (options.emitter && !_utils.is.func(options.emitter)) {
|
|
throw new Error('`options.emitter` passed to the Saga middleware is not a function!');
|
|
}
|
|
|
|
function sagaMiddleware(_ref2) {
|
|
var getState = _ref2.getState,
|
|
dispatch = _ref2.dispatch;
|
|
|
|
var sagaEmitter = (0, _channel.emitter)();
|
|
sagaEmitter.emit = (options.emitter || _utils.ident)(sagaEmitter.emit);
|
|
|
|
sagaMiddleware.run = _runSaga.runSaga.bind(null, {
|
|
context: context,
|
|
subscribe: sagaEmitter.subscribe,
|
|
dispatch: dispatch,
|
|
getState: getState,
|
|
sagaMonitor: sagaMonitor,
|
|
logger: logger,
|
|
onError: onError
|
|
});
|
|
|
|
return function (next) {
|
|
return function (action) {
|
|
if (sagaMonitor && sagaMonitor.actionDispatched) {
|
|
sagaMonitor.actionDispatched(action);
|
|
}
|
|
var result = next(action); // hit reducers
|
|
sagaEmitter.emit(action);
|
|
return result;
|
|
};
|
|
};
|
|
}
|
|
|
|
sagaMiddleware.run = function () {
|
|
throw new Error('Before running a Saga, you must mount the Saga middleware on the Store using applyMiddleware');
|
|
};
|
|
|
|
sagaMiddleware.setContext = function (props) {
|
|
(0, _utils.check)(props, _utils.is.object, (0, _utils.createSetContextWarning)('sagaMiddleware', props));
|
|
_utils.object.assign(context, props);
|
|
};
|
|
|
|
return sagaMiddleware;
|
|
} |