aboutsummaryrefslogtreecommitdiff
path: root/node_modules/vinyl-fs/lib/sink.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
committerFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
commitcc97a4dd2a967e1c2273bd5f4c5f49a5bf2e2585 (patch)
tree92c5d88706a6ffc654d1b133618d357890e7096b /node_modules/vinyl-fs/lib/sink.js
parent3771b4d6b67b34c130f3a9a1a15f42deefdb2eda (diff)
remove node_modules
Diffstat (limited to 'node_modules/vinyl-fs/lib/sink.js')
-rw-r--r--node_modules/vinyl-fs/lib/sink.js53
1 files changed, 0 insertions, 53 deletions
diff --git a/node_modules/vinyl-fs/lib/sink.js b/node_modules/vinyl-fs/lib/sink.js
deleted file mode 100644
index cfab46980..000000000
--- a/node_modules/vinyl-fs/lib/sink.js
+++ /dev/null
@@ -1,53 +0,0 @@
-'use strict';
-
-var Writable = require('readable-stream/writable');
-
-function listenerCount(stream, evt) {
- return stream.listeners(evt).length;
-}
-
-function hasListeners(stream) {
- return !!(listenerCount(stream, 'readable') || listenerCount(stream, 'data'));
-}
-
-function sink(stream) {
- var sinkAdded = false;
- var sinkStream = new Writable({
- objectMode: true,
- write: function(file, enc, cb) {
- cb();
- },
- });
-
- function addSink() {
- if (sinkAdded) {
- return;
- }
-
- if (hasListeners(stream)) {
- return;
- }
-
- sinkAdded = true;
- stream.pipe(sinkStream);
- }
-
- function removeSink(evt) {
- if (evt !== 'readable' && evt !== 'data') {
- return;
- }
-
- if (hasListeners(stream)) {
- sinkAdded = false;
- stream.unpipe(sinkStream);
- }
- }
-
- stream.on('newListener', removeSink);
- stream.on('removeListener', removeSink);
- stream.on('removeListener', addSink);
-
- return addSink;
-}
-
-module.exports = sink;