Research
Security News
Quasar RAT Disguised as an npm Package for Detecting Vulnerabilities in Ethereum Smart Contracts
Socket researchers uncover a malicious npm package posing as a tool for detecting vulnerabilities in Etherium smart contracts.
separate-stream
Advanced tools
Separates the chunks of one writable stream into multiple readable streams.
The package exports the SeparateStream
class. It can be imported like this:
const SeparateStream = require('separate-stream')
Creates a new instance of SeparateStream
that implements a Writable
stream interface.
All chunks written to the Writable
interface are forwarded to a Readable
stream that is given as an argument to the change
callback function.
Every chunk after the first chunk is handed over to the split
function that must return a boolean value which must be true
if a new stream should be started.
The map
callback allows translating incoming chunks before they are forwarded.
The following options are supported:
async change(stream, chunk)
: A callback function that is called whenever a new stream is started.
It will be called at least once for the first chunk.
Stream processing will wait until the function returned.
(default: () => {}
)split(chunk)
: A callback function that controls when to change to the next output stream.
A new output stream is started if the function returns true
.
(default: () => false
)map(chunk)
: A callback function that translates incoming chunks.
(default: v => v
)This example splits the incoming stream whenever there is an o
in the chunk.
The chunks are translated to upper case.
const { promisify } = require('util')
const { finished, Readable } = require('readable-stream')
const SeparateStream = require('..')
async function main () {
const input = new Readable({ objectMode: true, read: () => {} })
const separateStream = new SeparateStream({
change: stream => {
console.log('new stream!')
stream.on('data', chunk => console.log(chunk))
},
split: chunk => {
return chunk.includes('o')
},
map: v => v.toUpperCase()
})
input.push('this')
input.push('stream')
input.push('is')
input.push('separated')
input.push('to')
input.push('multiple')
input.push('output')
input.push('streams')
input.push(null)
input.pipe(separateStream)
await promisify(finished)(separateStream)
}
main()
FAQs
Separate one stream into multiple streams
The npm package separate-stream receives a total of 1,938 weekly downloads. As such, separate-stream popularity was classified as popular.
We found that separate-stream demonstrated a not healthy version release cadence and project activity because the last version was released a year ago. It has 1 open source maintainer collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Research
Security News
Socket researchers uncover a malicious npm package posing as a tool for detecting vulnerabilities in Etherium smart contracts.
Security News
Research
A supply chain attack on Rspack's npm packages injected cryptomining malware, potentially impacting thousands of developers.
Research
Security News
Socket researchers discovered a malware campaign on npm delivering the Skuld infostealer via typosquatted packages, exposing sensitive data.