New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@ebflat9/fp

Package Overview
Dependencies
Maintainers
1
Versions
160
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@ebflat9/fp - npm Package Compare versions

Comparing version 1.1.8 to 1.1.9

babel.config.json

9

package.json
{
"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"
}
}

50

src/rx.js

@@ -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 @@ }

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc