How to use the duplex function from event-stream

util.js

GitHub: spiffcode/ghedit

63
64
65
66
67
68
69
70
71
72
        if (state === 'idle') {
            eventuallyRun();
        }
    });

    return es.duplex(input, output);
};

exports.fixWin32DirectoryPermissions = () => {
    if (!/win32/.test(process.platform)) {

50

332

18

+ 19 other calls in file

request_tunnel.js

GitHub: johncant/node-http-tunnel

98
99
100
101
102
103
104
105
106

this.TCPConnection = function(hash, readyCallback) {
  var sp = new_stream_pair();
  $this.send_queue.push({method: 'open', stream_id: sp[0].stream_id, port: hash.port, host: hash.host});
  $this.open_queue[sp[0].stream_id] = function() {
    var result =  es.duplex(sp[1], sp[0]);
    readyCallback(result);
  };
}

24

74

7