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/compress-commons/lib/archivers/archive-output-stream.js | |
| parent | 3771b4d6b67b34c130f3a9a1a15f42deefdb2eda (diff) | |
remove node_modules
Diffstat (limited to 'node_modules/compress-commons/lib/archivers/archive-output-stream.js')
| -rw-r--r-- | node_modules/compress-commons/lib/archivers/archive-output-stream.js | 117 |
1 files changed, 0 insertions, 117 deletions
diff --git a/node_modules/compress-commons/lib/archivers/archive-output-stream.js b/node_modules/compress-commons/lib/archivers/archive-output-stream.js deleted file mode 100644 index f98da7b0d..000000000 --- a/node_modules/compress-commons/lib/archivers/archive-output-stream.js +++ /dev/null @@ -1,117 +0,0 @@ -/**
- * node-compress-commons
- *
- * Copyright (c) 2014 Chris Talkington, contributors.
- * Licensed under the MIT license.
- * https://github.com/archiverjs/node-compress-commons/blob/master/LICENSE-MIT
- */
-var inherits = require('util').inherits;
-var Transform = require('readable-stream').Transform;
-
-var ArchiveEntry = require('./archive-entry');
-var util = require('../util');
-
-var ArchiveOutputStream = module.exports = function(options) {
- if (!(this instanceof ArchiveOutputStream)) {
- return new ArchiveOutputStream(options);
- }
-
- Transform.call(this, options);
-
- this.offset = 0;
- this._archive = {
- finish: false,
- finished: false,
- processing: false
- };
-};
-
-inherits(ArchiveOutputStream, Transform);
-
-ArchiveOutputStream.prototype._appendBuffer = function(zae, source, callback) {
- // scaffold only
-};
-
-ArchiveOutputStream.prototype._appendStream = function(zae, source, callback) {
- // scaffold only
-};
-
-ArchiveOutputStream.prototype._emitErrorCallback = function(err) {
- if (err) {
- this.emit('error', err);
- }
-};
-
-ArchiveOutputStream.prototype._finish = function(ae) {
- // scaffold only
-};
-
-ArchiveOutputStream.prototype._normalizeEntry = function(ae) {
- // scaffold only
-};
-
-ArchiveOutputStream.prototype._transform = function(chunk, encoding, callback) {
- callback(null, chunk);
-};
-
-ArchiveOutputStream.prototype.entry = function(ae, source, callback) {
- source = source || null;
-
- if (typeof callback !== 'function') {
- callback = this._emitErrorCallback.bind(this);
- }
-
- if (!(ae instanceof ArchiveEntry)) {
- callback(new Error('not a valid instance of ArchiveEntry'));
- return;
- }
-
- if (this._archive.finish || this._archive.finished) {
- callback(new Error('unacceptable entry after finish'));
- return;
- }
-
- if (this._archive.processing) {
- callback(new Error('already processing an entry'));
- return;
- }
-
- this._archive.processing = true;
- this._normalizeEntry(ae);
- this._entry = ae;
-
- source = util.normalizeInputSource(source);
-
- if (Buffer.isBuffer(source)) {
- this._appendBuffer(ae, source, callback);
- } else if (util.isStream(source)) {
- this._appendStream(ae, source, callback);
- } else {
- this._archive.processing = false;
- callback(new Error('input source must be valid Stream or Buffer instance'));
- return;
- }
-
- return this;
-};
-
-ArchiveOutputStream.prototype.finish = function() {
- if (this._archive.processing) {
- this._archive.finish = true;
- return;
- }
-
- this._finish();
-};
-
-ArchiveOutputStream.prototype.getBytesWritten = function() {
- return this.offset;
-};
-
-ArchiveOutputStream.prototype.write = function(chunk, cb) {
- if (chunk) {
- this.offset += chunk.length;
- }
-
- return Transform.prototype.write.call(this, chunk, cb);
-};
\ No newline at end of file |