@ebflat9/fp
Advanced tools
Comparing version 1.1.8 to 1.1.9
{ | ||
"name": "@ebflat9/fp", | ||
"version": "1.1.8", | ||
"version": "1.1.9", | ||
"description": "my fp utils", | ||
@@ -22,3 +22,10 @@ "main": "index.js", | ||
"core-js": "^3.18.3" | ||
}, | ||
"devDependencies": { | ||
"@babel/core": "^7.15.8", | ||
"@babel/preset-env": "^7.15.8", | ||
"@rollup/plugin-babel": "^5.3.0", | ||
"@rollup/plugin-commonjs": "^21.0.1", | ||
"@rollup/plugin-node-resolve": "^13.0.6" | ||
} | ||
} |
@@ -17,30 +17,28 @@ import { curry } from './combinators.js' | ||
if (ReadableStream === undefined) { | ||
import('stream').then(({ Readable }) => { | ||
Object.defineProperty(Observable, 'fromGenerator', { | ||
value(generator) { | ||
return new Observable(observer => { | ||
Readable.from(generator) | ||
.on('data', observer.next.bind(observer)) | ||
.on('end', observer.complete.bind(observer)) | ||
}) | ||
}, | ||
enumerable: false, | ||
writable: false, | ||
configurable: false, | ||
}) | ||
const { Readable } = await import('stream') | ||
Object.defineProperty(Observable, 'fromGenerator', { | ||
value(generator) { | ||
return new Observable(observer => { | ||
Readable.from(generator) | ||
.on('data', observer.next.bind(observer)) | ||
.on('end', observer.complete.bind(observer)) | ||
}) | ||
}, | ||
enumerable: false, | ||
writable: false, | ||
configurable: false, | ||
}) | ||
} else { | ||
import('./web-streams.js').then(() => { | ||
Object.defineProperty(Observable, 'fromGenerator', { | ||
value(generator) { | ||
return new Observable(observer => { | ||
ReadableStream.from(generator) | ||
.on('data', observer.next.bind(observer)) | ||
.on('end', observer.complete.bind(observer)) | ||
}) | ||
}, | ||
enumerable: false, | ||
writable: false, | ||
configurable: false, | ||
}) | ||
await import('./web-streams.js') | ||
Object.defineProperty(Observable, 'fromGenerator', { | ||
value(generator) { | ||
return new Observable(observer => { | ||
ReadableStream.from(generator) | ||
.on('data', observer.next.bind(observer)) | ||
.on('end', observer.complete.bind(observer)) | ||
}) | ||
}, | ||
enumerable: false, | ||
writable: false, | ||
configurable: false, | ||
}) | ||
@@ -47,0 +45,0 @@ } |
180217
17
5711
5
2