'a'

mh-two-thousand-and-two

2024-04-12 44d2c92345cd156a59fc327b3060292a282d2893

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
const isFn = require('./isFn');
const extend = require('./extend');
const inherits = require('./inherits');
 
const Transform = require('stream').Transform;
 
exports = through(function(opts, transform, flush) {
    const t = new Transform(opts);
 
    t._transform = transform;
    if (flush) t._flush = flush;
 
    return t;
});
 
exports.obj = through(function(opts, transform, flush) {
    const t = new Transform(
        extend(
            {
                objectMode: true,
                highWaterMark: 16
            },
            opts
        )
    );
 
    t._transform = transform;
    if (flush) t._flush = flush;
 
    return t;
});
 
exports.ctor = through(function(opts, transform, flush) {
    function Through(override) {
        if (!(this instanceof Through)) return new Through(override);
 
        Transform.call(this, extend(opts, override));
    }
 
    inherits(Through, Transform);
 
    const proto = Through.prototype;
    proto._transform = transform;
    if (flush) proto._flush = flush;
 
    return Through;
});
 
function through(streamFactory) {
    return function(opts, transform, flush) {
        if (isFn(opts)) {
            flush = transform;
            transform = opts;
            opts = {};
        }
 
        if (!isFn(transform)) transform = defTransform;
        if (!isFn(flush)) flush = null;
 
        return streamFactory(opts, transform, flush);
    };
}
 
function defTransform(chunk, enc, cb) {
    cb(null, chunk);
}
 
module.exports = exports;