diff options
| author | Florian Dold <florian.dold@gmail.com> | 2019-03-27 21:01:33 +0100 | 
|---|---|---|
| committer | Florian Dold <florian.dold@gmail.com> | 2019-03-27 21:01:33 +0100 | 
| commit | cc97a4dd2a967e1c2273bd5f4c5f49a5bf2e2585 (patch) | |
| tree | 92c5d88706a6ffc654d1b133618d357890e7096b /node_modules/vinyl-fs/lib/sink.js | |
| parent | 3771b4d6b67b34c130f3a9a1a15f42deefdb2eda (diff) | |
remove node_modules
Diffstat (limited to 'node_modules/vinyl-fs/lib/sink.js')
| -rw-r--r-- | node_modules/vinyl-fs/lib/sink.js | 53 | 
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;  | 
