extract-base-iterator

Base iterator for extract iterators like tar-iterator and zip-iterator.

// asyncIterator

1var assert = require('assert');
2var BaseIterator = require('extract-base-iterator'));
3
4// extend BaseIterator (see tests, tar-iterator, zip-iterator for examples)
5
6(async function() {
7  var iterator = new YourIterator();
8
9  try {
10    const links = [];
11    for await (const entry of iterator) {
12      if (entry.type === 'link') links.unshift(entry);
13      else if (entry.type === 'symlink') links.push(entry);
14      else await entry.create(dest, options);
15    }
16
17    // create links after directories and files
18    for (const entry of links) await entry.create(dest, options);
19  } catch (err) {
20    }
21
22  iterator.destroy();
23  iterator = null;
24})();

// Async / Await

1var assert = require('assert');
2var BaseIterator = require('extract-base-iterator'));
3
4// extend BaseIterator (see tests, tar-iterator, zip-iterator for examples)
5
6var iterator = new YourIterator();
7
8// one by one
9(async function() {
10  let iterator = new YourIterator();
11
12  try {
13    const links = [];
14    for await (const entry of iterator) {
15      if (entry.type === 'link') links.unshift(entry);
16      else if (entry.type === 'symlink') links.push(entry);
17      else await entry.create(dest, options);
18    }
19
20    // create links after directories and files
21    for (const entry of links) await entry.create(dest, options);
22  } catch (err) {
23    }
24
25  iterator.destroy();
26  iterator = null;
27})();
28
29// infinite concurrency
30(async function() {
31  let iterator = new YourIterator();
32
33  try {
34    const links = [];
35    await iterator.forEach(
36      async function (entry) {
37        if (entry.type === 'link') links.unshift(entry);
38        else if (entry.type === 'symlink') links.push(entry);
39        else await entry.create(dest, options);
40      },
41      { concurrency: Infinity }
42    );
43
44    // create links after directories and files
45    for (const entry of links) await entry.create(dest, options);
46  } catch (err) {
47    aseert.ok(!err);
48  }
49
50  iterator.destroy();
51  iterator = null;
52})();

// Callbacks

1var assert = require('assert');
2var Queue = require('queue-cb');
3var BaseIterator = require('extract-base-iterator'));
4
5// extend BaseIterator (see tests, tar-iterator, zip-iterator for examples)
6
7var iterator = new YourIterator();
8
9// one by one
10var links = [];
11iterator.forEach(
12  function (entry, callback) {
13    if (entry.type === 'link') {
14      links.unshift(entry);
15      callback();
16    } else if (entry.type === 'symlink') {
17      links.push(entry);
18      callback();
19    } else entry.create(dest, options, callback);
20  },
21  { callbacks: true, concurrency: 1 },
22  function (err) {
23  
24    // create links after directories and files
25    var queue = new Queue();
26    for (var index = 0; index < links.length; index++) {
27      var entry = links[index];
28      queue.defer(entry.create.bind(entry, dest, options));
29    }
30    queue.await(callback);
31
32    iterator.destroy();
33    iterator = null;
34  }
35);