light-observable
Advanced tools
Comparing version 2.5.0 to 2.5.1
import { getSpecies } from '../helpers/getSpecies'; | ||
const subscribe = (sources, observer, onSubscribe) => onSubscribe(sources[0].subscribe({ | ||
next(value) { | ||
observer.next(value); | ||
}, | ||
error(e) { | ||
observer.error(e); | ||
}, | ||
complete() { | ||
if (sources.length > 1) { | ||
subscribe(sources.slice(1), observer, onSubscribe); | ||
const subscribe = (sources, observer, onSubscribe) => { | ||
return sources[0].subscribe({ | ||
start(s) { | ||
onSubscribe(s); | ||
}, | ||
next(value) { | ||
observer.next(value); | ||
}, | ||
error(e) { | ||
observer.error(e); | ||
}, | ||
complete() { | ||
if (sources.length > 1) { | ||
subscribe(sources.slice(1), observer, onSubscribe); | ||
} | ||
else { | ||
observer.complete(); | ||
} | ||
} | ||
else { | ||
observer.complete(); | ||
} | ||
} | ||
})); | ||
}); | ||
}; | ||
export function concat(...sources) { | ||
@@ -19,0 +24,0 @@ const C = getSpecies(sources[0]); |
{ | ||
"name": "light-observable", | ||
"version": "2.5.0", | ||
"version": "2.5.1", | ||
"description": "Light observable ponyfill", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
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
57165
941