diff options
Diffstat (limited to 'node_modules/merge-stream')
-rw-r--r-- | node_modules/merge-stream/LICENSE | 21 | ||||
-rw-r--r-- | node_modules/merge-stream/README.md | 55 | ||||
-rw-r--r-- | node_modules/merge-stream/index.js | 41 | ||||
-rw-r--r-- | node_modules/merge-stream/package.json | 21 |
4 files changed, 0 insertions, 138 deletions
diff --git a/node_modules/merge-stream/LICENSE b/node_modules/merge-stream/LICENSE deleted file mode 100644 index 94a4c0a07..000000000 --- a/node_modules/merge-stream/LICENSE +++ /dev/null @@ -1,21 +0,0 @@ -The MIT License (MIT) - -Copyright (c) Stephen Sugden <me@stephensugden.com> (stephensugden.com) - -Permission is hereby granted, free of charge, to any person obtaining a copy -of this software and associated documentation files (the "Software"), to deal -in the Software without restriction, including without limitation the rights -to use, copy, modify, merge, publish, distribute, sublicense, and/or sell -copies of the Software, and to permit persons to whom the Software is -furnished to do so, subject to the following conditions: - -The above copyright notice and this permission notice shall be included in -all copies or substantial portions of the Software. - -THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR -IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, -FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE -AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER -LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, -OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN -THE SOFTWARE. diff --git a/node_modules/merge-stream/README.md b/node_modules/merge-stream/README.md deleted file mode 100644 index 966bde69c..000000000 --- a/node_modules/merge-stream/README.md +++ /dev/null @@ -1,55 +0,0 @@ -# merge-stream - -Merge (interleave) a bunch of streams. - -[](http://travis-ci.org/grncdr/merge-stream) - -## Synopsis - -```javascript -var stream1 = new Stream(); -var stream2 = new Stream(); - -var merged = mergeStream(stream1, stream2); - -var stream3 = new Stream(); -merged.add(stream3); -merged.isEmpty(); -//=> false -``` - -## Description - -This is adapted from [event-stream](https://github.com/dominictarr/event-stream) separated into a new module, using Streams3. - -## API - -### `mergeStream` - -Type: `function` - -Merges an arbitrary number of streams. Returns a merged stream. - -#### `merged.add` - -A method to dynamically add more sources to the stream. The argument supplied to `add` can be either a source or an array of sources. - -#### `merged.isEmpty` - -A method that tells you if the merged stream is empty. - -When a stream is "empty" (aka. no sources were added), it could not be returned to a gulp task. - -So, we could do something like this: - -```js -stream = require('merge-stream')(); -// Something like a loop to add some streams to the merge stream -// stream.add(streamA); -// stream.add(streamB); -return stream.isEmpty() ? null : stream; -``` - -## License - -MIT diff --git a/node_modules/merge-stream/index.js b/node_modules/merge-stream/index.js deleted file mode 100644 index f907ad65a..000000000 --- a/node_modules/merge-stream/index.js +++ /dev/null @@ -1,41 +0,0 @@ -'use strict'; - -var PassThrough = require('readable-stream/passthrough') - -module.exports = function (/*streams...*/) { - var sources = [] - var output = new PassThrough({objectMode: true}) - - output.setMaxListeners(0) - - output.add = add - output.isEmpty = isEmpty - - output.on('unpipe', remove) - - Array.prototype.slice.call(arguments).forEach(add) - - return output - - function add (source) { - if (Array.isArray(source)) { - source.forEach(add) - return this - } - - sources.push(source); - source.once('end', remove.bind(null, source)) - source.once('error', output.emit.bind(output, 'error')) - source.pipe(output, {end: false}) - return this - } - - function isEmpty () { - return sources.length == 0; - } - - function remove (source) { - sources = sources.filter(function (it) { return it !== source }) - if (!sources.length && output.readable) { output.end() } - } -} diff --git a/node_modules/merge-stream/package.json b/node_modules/merge-stream/package.json deleted file mode 100644 index 722df5491..000000000 --- a/node_modules/merge-stream/package.json +++ /dev/null @@ -1,21 +0,0 @@ -{ - "name": "merge-stream", - "version": "1.0.1", - "description": "Create a stream that emits events from multiple other streams", - "files": [ - "index.js" - ], - "scripts": { - "test": "istanbul cover test.js && istanbul check-cover --statements 100 --branches 100" - }, - "repository": "grncdr/merge-stream", - "author": "Stephen Sugden <me@stephensugden.com>", - "license": "MIT", - "dependencies": { - "readable-stream": "^2.0.1" - }, - "devDependencies": { - "from2": "^2.0.3", - "istanbul": "^0.3.2" - } -} |