Comparing version 1.1.9 to 1.1.10
@@ -42,3 +42,1 @@ var noop = function () {} | ||
{ | ||
"name": "pull-cat", | ||
"description": "concatenate pull-streams", | ||
"version": "1.1.9", | ||
"homepage": "https://github.com/dominictarr/pull-cat", | ||
"version": "1.1.10", | ||
"homepage": "https://github.com/pull-stream/pull-cat", | ||
"repository": { | ||
"type": "git", | ||
"url": "git://github.com/dominictarr/pull-cat.git" | ||
"url": "git://github.com/pull-stream/pull-cat.git" | ||
}, | ||
"devDependencies": { | ||
"pull-abortable": "~4.1.0", | ||
"tape": "~1.0", | ||
"pull-pushable": "~1.1.4", | ||
"pull-stream": "^3.1.0", | ||
"tape": "^4.4.0" | ||
"pull-stream": "^3.4.2" | ||
}, | ||
@@ -16,0 +16,0 @@ "scripts": { |
# pull-cat | ||
concatinate pull-streams | ||
concatenate pull-streams | ||
<<<<<<< HEAD | ||
```shell | ||
npm install --save pull-cat | ||
``` | ||
## example | ||
======= | ||
construct a new source stream from a sequential list of source streams, | ||
@@ -15,13 +22,39 @@ reading from each one in turn until it ends, then the next, etc. | ||
# example | ||
>>>>>>> master | ||
``` js | ||
```js | ||
var cat = require('pull-cat') | ||
var pull = require('pull-stream') | ||
<<<<<<< HEAD | ||
pull( | ||
cat([ | ||
pull.values([1,2,3]), | ||
pull.values([4,5,6]) | ||
]), | ||
pull.log() | ||
) | ||
// 1 | ||
// 2 | ||
// 3 | ||
// 4 | ||
// 5 | ||
// 6 | ||
======= | ||
pull( | ||
cat([pull.values([1,2,3]), pull.values([4,5,6])]), | ||
sink... | ||
) | ||
>>>>>>> master | ||
``` | ||
Reads from the each stream until it is finished. | ||
## api | ||
### `cat = require('pull-cat')` | ||
### `stream = cat(streams)` | ||
Reads from each stream in `streams` until finished. | ||
If a stream errors, stop all the streams. | ||
@@ -28,0 +61,0 @@ if the concatenated stream is aborted, abort all the streams, |
@@ -1,3 +0,1 @@ | ||
var pull = require('pull-stream') | ||
@@ -8,4 +6,4 @@ var cat = require('../') | ||
var Abortable = require('pull-abortable') | ||
test('cat', function (t) { | ||
pull( | ||
@@ -20,7 +18,5 @@ cat([pull.values([1,2,3]), pull.values([4,5,6])]), | ||
) | ||
}) | ||
test('cat - with empty', function (t) { | ||
pull( | ||
@@ -35,3 +31,2 @@ cat([pull.values([1,2,3]), null, pull.values([4,5,6])]), | ||
) | ||
}) | ||
@@ -132,2 +127,16 @@ | ||
test('take cat', function (t) { | ||
pull( | ||
cat([ | ||
pull(pull.values([1,2,3]), pull.take(2)), | ||
pull(pull.values([8,7,6,5]), pull.take(3)), | ||
]), | ||
pull.collect(function (err, data) { | ||
t.error(err) | ||
t.deepEqual(data, [1,2,8,7,6]) | ||
t.end() | ||
}) | ||
) | ||
}) | ||
test('abort streams after error', function (t) { | ||
@@ -154,1 +163,2 @@ var err = new Error('test error') | ||
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
6859
176
68