| 1 | var through = require('through2');
|
| 2 | var replace = require('./lib/replace.js');
|
| 3 |
|
| 4 | module.exports = function apply (b, opts) {
|
| 5 | b.pipeline.get('label').push(through.obj(function (row, enc, next) {
|
| 6 | row.source = replace(row.source, row.deps);
|
| 7 | var deps = {};
|
| 8 | for (var key in row.deps) {
|
| 9 | deps[row.deps[key]] = row.deps[key];
|
| 10 | }
|
| 11 | row.deps = deps;
|
| 12 | this.push(row);
|
| 13 | next();
|
| 14 | }));
|
| 15 | b.once('reset', function () { apply(b, opts) });
|
| 16 | };
|