heyujie
2021-06-07 8f8155aa4c83f7c2577ac123add550766b6a7ce3
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
'use strict';
 
var aFrom          = require('es5-ext/array/from')
  , remove         = require('es5-ext/array/#/remove')
  , value          = require('es5-ext/object/valid-object')
  , d              = require('d')
  , emit           = require('./').methods.emit
 
  , defineProperty = Object.defineProperty
  , hasOwnProperty = Object.prototype.hasOwnProperty
  , getOwnPropertyDescriptor = Object.getOwnPropertyDescriptor;
 
module.exports = function (e1, e2/*, name*/) {
    var pipes, pipe, desc, name;
 
    (value(e1) && value(e2));
    name = arguments[2];
    if (name === undefined) name = 'emit';
 
    pipe = {
        close: function () { remove.call(pipes, e2); }
    };
    if (hasOwnProperty.call(e1, '__eePipes__')) {
        (pipes = e1.__eePipes__).push(e2);
        return pipe;
    }
    defineProperty(e1, '__eePipes__', d('c', pipes = [e2]));
    desc = getOwnPropertyDescriptor(e1, name);
    if (!desc) {
        desc = d('c', undefined);
    } else {
        delete desc.get;
        delete desc.set;
    }
    desc.value = function () {
        var i, emitter, data = aFrom(pipes);
        emit.apply(this, arguments);
        for (i = 0; (emitter = data[i]); ++i) emit.apply(emitter, arguments);
    };
    defineProperty(e1, name, desc);
    return pipe;
};