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
69
70
71
72
73
74
75
76
77
| 'use strict';
|
| // We define these manually to ensure they're always copied
| // even if they would move up the prototype chain
| // https://nodejs.org/api/http.html#http_class_http_incomingmessage
| const knownProperties = [
| 'aborted',
| 'complete',
| 'headers',
| 'httpVersion',
| 'httpVersionMinor',
| 'httpVersionMajor',
| 'method',
| 'rawHeaders',
| 'rawTrailers',
| 'setTimeout',
| 'socket',
| 'statusCode',
| 'statusMessage',
| 'trailers',
| 'url'
| ];
|
| module.exports = (fromStream, toStream) => {
| if (toStream._readableState.autoDestroy) {
| throw new Error('The second stream must have the `autoDestroy` option set to `false`');
| }
|
| const fromProperties = new Set(Object.keys(fromStream).concat(knownProperties));
|
| const properties = {};
|
| for (const property of fromProperties) {
| // Don't overwrite existing properties.
| if (property in toStream) {
| continue;
| }
|
| properties[property] = {
| get() {
| const value = fromStream[property];
| const isFunction = typeof value === 'function';
|
| return isFunction ? value.bind(fromStream) : value;
| },
| set(value) {
| fromStream[property] = value;
| },
| enumerable: true,
| configurable: false
| };
| }
|
| Object.defineProperties(toStream, properties);
|
| fromStream.once('aborted', () => {
| toStream.destroy();
|
| toStream.emit('aborted');
| });
|
| fromStream.once('close', () => {
| if (fromStream.complete) {
| if (toStream.readable) {
| toStream.once('end', () => {
| toStream.emit('close');
| });
| } else {
| toStream.emit('close');
| }
| } else {
| toStream.emit('close');
| }
| });
|
| return toStream;
| };
|
|
