Security News
Introducing the Socket Python SDK
The initial version of the Socket Python SDK is now on PyPI, enabling developers to more easily interact with the Socket REST API in Python projects.
pull-pushable
Advanced tools
A pull-stream with a pushable interface.
Use this when you really can't pull from your source. For example, often I like to have a "live" stream. This would read a series of data, first old data, but then stay open and read new data as it comes in.
In that case, the new data needs to be queued up while the old data is read, and also, the rate things are pushed into the queue doesn't affect the rate of reads.
If there is no realtime aspect to this stream, it's likely that you don't need pushable.
Instead try just using pull.values(array)
.
var Pushable = require('pull-pushable')
var pull = require('pull-stream')
var p = Pushable()
pull(p, pull.drain(console.log))
p.push(1)
p.end()
Also, can provide a listener for when the stream is closed.
var Pushable = require('pull-pushable')
var pull = require('pull-stream')
var p = Pushable(function (err) {
console.log('stream closed!')
})
//read 3 times then abort.
pull(p, pull.take(3), pull.drain(console.log))
p.push(1)
p.push(2)
p.push(3)
p.push(4) //stream will be aborted before this is output
When giving the stream away and you don't want the user to have the push
/end
functions,
you can pass a separated
option. It returns { push, end, source, buffer }
.
function createStream () {
var p = Pushable(true) // optionally pass `onDone` after it
somethingAsync((err, data) => {
if (err) return p.end(err)
p.push(data)
})
return p.source
}
var stream = createStream()
// stream.push === undefined
The current buffer array is exposed as buffer
if you need to inspect or
manipulate it.
MIT
FAQs
pull-stream with a push interface
The npm package pull-pushable receives a total of 33,457 weekly downloads. As such, pull-pushable popularity was classified as popular.
We found that pull-pushable 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.
Security News
The initial version of the Socket Python SDK is now on PyPI, enabling developers to more easily interact with the Socket REST API in Python projects.
Security News
Floating dependency ranges in npm can introduce instability and security risks into your project by allowing unverified or incompatible versions to be installed automatically, leading to unpredictable behavior and potential conflicts.
Security News
A new Rust RFC proposes "Trusted Publishing" for Crates.io, introducing short-lived access tokens via OIDC to improve security and reduce risks associated with long-lived API tokens.