1.0.1 • Published 3 months ago
zip-iterator v1.0.1
zip-iterator
Extract contents from zip archive type using an iterator API using streams or paths. Use stream interface and pipe transforms to add decompression algorithms.
// asyncIterator
var assert = require('assert');
var fs = require('fs');
var ZipIterator = require('zip-iterator'));
(async function() {
let iterator = new ZipIterator('/path/to/archive');
try {
const links = [];
for await (const entry of iterator) {
if (entry.type === 'link') links.unshift(entry);
else if (entry.type === 'symlink') links.push(entry);
else await entry.create(dest, options);
}
// create links after directories and files
for (const entry of links) await entry.create(dest, options);
} catch (err) {
assert.ok(!err);
}
iterator.destroy();
iterator = null;
})();
(async function() {
let iterator = new ZipIterator(fs.createReadStream('/path/to/archive'));
try {
const links = [];
for await (const entry of iterator) {
if (entry.type === 'link') links.unshift(entry);
else if (entry.type === 'symlink') links.push(entry);
else await entry.create(dest, options);
}
// create links after directories and files
for (const entry of links) await entry.create(dest, options);
} catch (err) {
assert.ok(!err);
}
iterator.destroy();
iterator = null;
})();
// Async / Await
var assert = require('assert');
var ZipIterator = require('zip-iterator'));
// one by one
(async function() {
let iterator = new ZipIterator('/path/to/archive');
const links = [];
let entry = await iterator.next();
while (entry) {
if (entry.type === 'link') links.unshift(entry);
else if (entry.type === 'symlink') links.push(entry);
else await entry.create(dest, options);
entry = await iterator.next();
}
// create links after directories and files
for (entry of links) {
await entry.create(dest, options);
}
iterator.destroy();
iterator = null;
})();
// infinite concurrency
(async function() {
let iterator = new ZipIterator('/path/to/archive');
try {
const links = [];
await iterator.forEach(
async function (entry) {
if (entry.type === 'link') links.unshift(entry);
else if (entry.type === 'symlink') links.push(entry);
else await entry.create(dest, options);
},
{ concurrency: Infinity }
);
// create links after directories and files
for (const entry of links) await entry.create(dest, options);
} catch (err) {
aseert.ok(!err);
}
iterator.destroy();
iterator = null;
})();
// Callbacks
var assert = require('assert');
var Queue = require('queue-cb');
var ZipIterator = require('zip-iterator'));
var iterator = new ZipIterator('/path/to/archive');
// one by one
var links = [];
iterator.forEach(
function (entry, callback) {
if (entry.type === 'link') {
links.unshift(entry);
callback();
} else if (entry.type === 'symlink') {
links.push(entry);
callback();
} else entry.create(dest, options, callback);
},
{ callbacks: true, concurrency: 1 },
function (err) {
assert.ok(!err);
// create links after directories and files
var queue = new Queue();
for (var index = 0; index < links.length; index++) {
var entry = links[index];
queue.defer(entry.create.bind(entry, dest, options));
}
queue.await(callback);
iterator.destroy();
iterator = null;
}
);
1.0.1
3 months ago
1.0.0
3 months ago
0.3.0
3 months ago
0.3.2
3 months ago
0.3.1
3 months ago
0.1.12
2 years ago
0.2.1
2 years ago
0.2.0
2 years ago
0.2.7
2 years ago
0.2.6
2 years ago
0.2.3
2 years ago
0.2.2
2 years ago
0.2.5
2 years ago
0.2.4
2 years ago
0.1.11
3 years ago
0.1.10
4 years ago
0.1.8
4 years ago
0.1.6
4 years ago
0.1.5
4 years ago
0.1.2
4 years ago
0.1.1
4 years ago
0.1.4
4 years ago
0.1.3
4 years ago
0.1.0
4 years ago