@redux-saga/core
Advanced tools
Comparing version 1.0.0 to 1.0.1
@@ -11,3 +11,3 @@ 'use strict'; | ||
var is = require('@redux-saga/is'); | ||
var __chunk_1 = require('./chunk-e088dd6b.js'); | ||
var __chunk_1 = require('./chunk-b4d357bd.js'); | ||
var redux = require('redux'); | ||
@@ -435,11 +435,18 @@ var deferred = _interopDefault(require('@redux-saga/deferred')); | ||
var next = function next(value) { | ||
if (value === void 0) { | ||
value = result; | ||
var resolved = false; | ||
var next = function next(arg) { | ||
if (!resolved) { | ||
resolved = true; // Only promises returned from fork will be interpreted. See #1573 | ||
return { | ||
value: result, | ||
done: !is.promise(result) | ||
}; | ||
} else { | ||
return { | ||
value: arg, | ||
done: true | ||
}; | ||
} | ||
return { | ||
value: value, | ||
done: !is.promise(value) | ||
}; | ||
}; | ||
@@ -446,0 +453,0 @@ |
@@ -6,4 +6,4 @@ import { CHANNEL_END_TYPE, MULTICAST, MATCH, SAGA_ACTION, CANCEL, SELF_CANCELLATION, TERMINATE, TASK, TASK_CANCEL, IO } from '@redux-saga/symbols'; | ||
import { string, array, stringableFunc, func, symbol, buffer, notUndef, promise, iterator, undef, object, channel } from '@redux-saga/is'; | ||
import { a as kTrue, b as expanding, c as check, d as none, e as once, f as remove, g as internalErr, h as TAKE, i as PUT, j as ALL, k as RACE, l as CALL, m as CPS, n as FORK, o as JOIN, p as CANCEL$1, q as SELECT, r as ACTION_CHANNEL, s as CANCELLED, t as FLUSH, u as GET_CONTEXT, v as SET_CONTEXT, w as getMetaInfo, x as noop, y as createAllStyleChildCallbacks, z as createEmptyArray, A as assignWithSymbols, B as makeIterator, C as shouldComplete, D as flatMap, E as getLocation, F as createSetContextWarning, G as asyncIteratorSymbol, H as shouldCancel, I as shouldTerminate, J as logError, K as wrapSagaDispatch, L as identity } from './chunk-585b854f.js'; | ||
export { U as buffers, V as detach } from './chunk-585b854f.js'; | ||
import { a as kTrue, b as expanding, c as check, d as none, e as once, f as remove, g as internalErr, h as TAKE, i as PUT, j as ALL, k as RACE, l as CALL, m as CPS, n as FORK, o as JOIN, p as CANCEL$1, q as SELECT, r as ACTION_CHANNEL, s as CANCELLED, t as FLUSH, u as GET_CONTEXT, v as SET_CONTEXT, w as getMetaInfo, x as noop, y as createAllStyleChildCallbacks, z as createEmptyArray, A as assignWithSymbols, B as makeIterator, C as shouldComplete, D as flatMap, E as getLocation, F as createSetContextWarning, G as asyncIteratorSymbol, H as shouldCancel, I as shouldTerminate, J as logError, K as wrapSagaDispatch, L as identity } from './chunk-e3ea3b33.js'; | ||
export { U as buffers, V as detach } from './chunk-e3ea3b33.js'; | ||
import { compose } from 'redux'; | ||
@@ -431,11 +431,18 @@ import deferred from '@redux-saga/deferred'; | ||
var next = function next(value) { | ||
if (value === void 0) { | ||
value = result; | ||
var resolved = false; | ||
var next = function next(arg) { | ||
if (!resolved) { | ||
resolved = true; // Only promises returned from fork will be interpreted. See #1573 | ||
return { | ||
value: result, | ||
done: !promise(result) | ||
}; | ||
} else { | ||
return { | ||
value: arg, | ||
done: true | ||
}; | ||
} | ||
return { | ||
value: value, | ||
done: !promise(value) | ||
}; | ||
}; | ||
@@ -442,0 +449,0 @@ |
@@ -11,3 +11,3 @@ 'use strict'; | ||
var is = require('@redux-saga/is'); | ||
var __chunk_1 = require('./chunk-254dd3a7.js'); | ||
var __chunk_1 = require('./chunk-affbe8eb.js'); | ||
var redux = require('redux'); | ||
@@ -382,11 +382,18 @@ var deferred = _interopDefault(require('@redux-saga/deferred')); | ||
var next = function next(value) { | ||
if (value === void 0) { | ||
value = result; | ||
var resolved = false; | ||
var next = function next(arg) { | ||
if (!resolved) { | ||
resolved = true; // Only promises returned from fork will be interpreted. See #1573 | ||
return { | ||
value: result, | ||
done: !is.promise(result) | ||
}; | ||
} else { | ||
return { | ||
value: arg, | ||
done: true | ||
}; | ||
} | ||
return { | ||
value: value, | ||
done: !is.promise(value) | ||
}; | ||
}; | ||
@@ -393,0 +400,0 @@ |
@@ -8,3 +8,3 @@ 'use strict'; | ||
var is = require('@redux-saga/is'); | ||
var __chunk_1 = require('./chunk-e088dd6b.js'); | ||
var __chunk_1 = require('./chunk-b4d357bd.js'); | ||
require('@redux-saga/delay-p'); | ||
@@ -11,0 +11,0 @@ |
import '@redux-saga/symbols'; | ||
import '@babel/runtime/helpers/esm/extends'; | ||
import { channel, stringableFunc, func, notUndef } from '@redux-saga/is'; | ||
import { B as makeIterator, M as take, N as fork, O as cancel, P as call, Q as actionChannel, R as sliding, S as delay, T as race, c as check } from './chunk-585b854f.js'; | ||
export { W as effectTypes, M as take, X as takeMaybe, Y as put, Z as putResolve, _ as all, T as race, P as call, $ as apply, a0 as cps, N as fork, a1 as spawn, a2 as join, O as cancel, a3 as select, Q as actionChannel, a4 as cancelled, a5 as flush, a6 as getContext, a7 as setContext, S as delay } from './chunk-585b854f.js'; | ||
import { B as makeIterator, M as take, N as fork, O as cancel, P as call, Q as actionChannel, R as sliding, S as delay, T as race, c as check } from './chunk-e3ea3b33.js'; | ||
export { W as effectTypes, M as take, X as takeMaybe, Y as put, Z as putResolve, _ as all, T as race, P as call, $ as apply, a0 as cps, N as fork, a1 as spawn, a2 as join, O as cancel, a3 as select, Q as actionChannel, a4 as cancelled, a5 as flush, a6 as getContext, a7 as setContext, S as delay } from './chunk-e3ea3b33.js'; | ||
import '@redux-saga/delay-p'; | ||
@@ -7,0 +7,0 @@ |
@@ -8,3 +8,3 @@ 'use strict'; | ||
var is = require('@redux-saga/is'); | ||
var __chunk_1 = require('./chunk-254dd3a7.js'); | ||
var __chunk_1 = require('./chunk-affbe8eb.js'); | ||
require('@redux-saga/delay-p'); | ||
@@ -11,0 +11,0 @@ |
@@ -307,6 +307,4 @@ import { Action, Middleware } from 'redux' | ||
* not provided, messages will not be buffered on this channel. | ||
* @param optional predicate function (`any => Boolean`) to filter incoming | ||
* messages. Only messages accepted by the matcher will be put on the channel. | ||
*/ | ||
export function eventChannel<T>(subscribe: Subscribe<T>, buffer?: Buffer<T>, matcher?: Predicate<T>): EventChannel<T> | ||
export function eventChannel<T>(subscribe: Subscribe<T>, buffer?: Buffer<T>): EventChannel<T> | ||
@@ -313,0 +311,0 @@ export type Subscribe<T> = (cb: (input: T | END) => void) => Unsubscribe |
{ | ||
"name": "@redux-saga/core", | ||
"version": "1.0.0", | ||
"version": "1.0.1", | ||
"description": "Saga middleware for Redux to handle Side Effects", | ||
@@ -46,6 +46,6 @@ "main": "./dist/redux-saga-core.cjs.js", | ||
"@babel/runtime": "^7.0.0", | ||
"@redux-saga/deferred": "^1.0.0", | ||
"@redux-saga/delay-p": "^1.0.0", | ||
"@redux-saga/is": "^1.0.0", | ||
"@redux-saga/symbols": "^1.0.0", | ||
"@redux-saga/deferred": "^1.0.1", | ||
"@redux-saga/delay-p": "^1.0.1", | ||
"@redux-saga/is": "^1.0.1", | ||
"@redux-saga/symbols": "^1.0.1", | ||
"@redux-saga/types": "^1.0.0", | ||
@@ -62,3 +62,3 @@ "redux": ">=0.10 <5", | ||
"babel-7-jest": "^21.3.3", | ||
"babel-plugin-annotate-pure-calls": "^0.3.0", | ||
"babel-plugin-annotate-pure-calls": "^0.4.0", | ||
"bundlesize": "^0.11.0", | ||
@@ -78,3 +78,3 @@ "jest": "^23.5.0", | ||
"typings": "./index.d.ts", | ||
"gitHead": "fc6a2e3d5b1aa37864a13be6db3115ad6afc1f1b" | ||
"gitHead": "876ac7bb9d049e9a0c9526b4396b3fd0364d3181" | ||
} |
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
259142
17
7990
42
Updated@redux-saga/deferred@^1.0.1
Updated@redux-saga/delay-p@^1.0.1
Updated@redux-saga/is@^1.0.1
Updated@redux-saga/symbols@^1.0.1