Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/austingebauer/devise.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/stdout-stream/index.js')
-rw-r--r--node_modules/stdout-stream/index.js53
1 files changed, 0 insertions, 53 deletions
diff --git a/node_modules/stdout-stream/index.js b/node_modules/stdout-stream/index.js
deleted file mode 100644
index a8ab752..0000000
--- a/node_modules/stdout-stream/index.js
+++ /dev/null
@@ -1,53 +0,0 @@
-var fs = require('fs');
-var Writable = require('readable-stream/writable');
-
-var exists = function(path) {
- try {
- return fs.existsSync(path);
- } catch (err) {
- return false;
- }
-};
-
-module.exports = function() {
- var s = new Writable({highWaterMark:0});
-
- var cb;
- var data;
- var tries = 0;
- var offset = 0;
-
- var write = function() {
- fs.write(1, data, offset, data.length - offset, null, onwrite);
- };
-
- var onwrite = function(err, written) {
- if (err && err.code === 'EPIPE') return cb()
- if (err && err.code === 'EAGAIN' && tries++ < 30) return setTimeout(write, 10);
- if (err) return cb(err);
-
- tries = 0;
- if (offset + written >= data.length) return cb();
-
- offset += written;
- write();
- };
-
- s._write = function(_data, enc, _cb) {
- offset = 0;
- cb = _cb;
- data = _data;
- write();
- };
-
- s._isStdio = true;
- s.isTTY = process.stdout.isTTY;
-
- s.on('finish', function() {
- fs.close(1, function(err) {
- if (err) s.emit('error', err);
- });
- });
-
- return s;
-}();