Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

pull-stream

Package Overview
Dependencies
Maintainers
1
Versions
87
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

pull-stream - npm Package Compare versions

Comparing version 2.22.0 to 2.22.2

9

docs/sinks.md

@@ -1,6 +0,5 @@

# Sinks
A Source is a stream that is not readable.
You *must* have a source at the start of a pipeline
A Sink is a stream that is not readable.
You *must* have a sink at the end of a pipeline
for data to move through.

@@ -16,2 +15,6 @@

See also:
* [Sources](https://github.com/dominictarr/pull-stream/blob/master/docs/sources.md)
* [Throughs](https://github.com/dominictarr/pull-stream/blob/master/docs/throughs.md)
## drain (op?, done?)

@@ -18,0 +21,0 @@

@@ -15,2 +15,6 @@ # Sources

See also:
* [Throughs](https://github.com/dominictarr/pull-stream/blob/master/docs/throughs.md)
* [Sinks](https://github.com/dominictarr/pull-stream/blob/master/docs/sinks.md)
## values (array | object)

@@ -17,0 +21,0 @@

@@ -8,6 +8,6 @@ # Throughs

Put through streams in-between sources and sinks,
Put through streams in-between [sources](https://github.com/dominictarr/pull-stream/blob/master/docs/sources.md) and [sinks](https://github.com/dominictarr/pull-stream/blob/master/docs/sinks.md),
like this:
``` js
```js
source()

@@ -22,3 +22,3 @@ .pipe(through()) //optional

``` js
```js
var throughABC = function () {

@@ -33,13 +33,17 @@ return throughA()

``` js
```js
source().pipe(throughABC()).pipe(sink())
```
See also:
* [Sources](https://github.com/dominictarr/pull-stream/blob/master/docs/sources.md)
* [Sinks](https://github.com/dominictarr/pull-stream/blob/master/docs/sinks.md)
## map (fun)
like `[].map(function (data) {return data})`
Like `[].map(function (data) {return data})`
## asyncMap (fun)
like `map` but the signature of `fun` must be
Like `map` but the signature of `fun` must be
`function (data, cb) { cb(null, data) }`

@@ -49,3 +53,3 @@

like `[].filter(function (data) {return true || false})`
Like `[].filter(function (data) {return true || false})`
only `data` where `test(data) == true` are let through

@@ -57,3 +61,3 @@ to the next stream.

like filter, but remove items where the filter returns true.
Like filter, but remove items where the filter returns true.

@@ -68,3 +72,3 @@ ## unique (prop)

filter unique items -- get the duplicates.
Filter unique items -- get the duplicates.
The inverse of `unique`

@@ -74,3 +78,3 @@

read from the source stream until `test` fails.
Read from the source stream until `test` fails.

@@ -90,3 +94,3 @@ ## group (length)

A async buffering stream.
An async buffering stream.

@@ -93,0 +97,0 @@ `highWaterMark` will eagerly read from the source stream,

{
"name": "pull-stream",
"description": "minimal pull stream",
"version": "2.22.0",
"version": "2.22.2",
"homepage": "https://github.com/dominictarr/pull-stream",

@@ -6,0 +6,0 @@ "repository": {

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