source: trip-planner-front/node_modules/end-of-stream/index.js@ 59329aa

Last change on this file since 59329aa was 6a3a178, checked in by Ema <ema_spirova@…>, 3 years ago

initial commit

  • Property mode set to 100644
File size: 2.6 KB
Line 
1var once = require('once');
2
3var noop = function() {};
4
5var isRequest = function(stream) {
6 return stream.setHeader && typeof stream.abort === 'function';
7};
8
9var isChildProcess = function(stream) {
10 return stream.stdio && Array.isArray(stream.stdio) && stream.stdio.length === 3
11};
12
13var eos = function(stream, opts, callback) {
14 if (typeof opts === 'function') return eos(stream, null, opts);
15 if (!opts) opts = {};
16
17 callback = once(callback || noop);
18
19 var ws = stream._writableState;
20 var rs = stream._readableState;
21 var readable = opts.readable || (opts.readable !== false && stream.readable);
22 var writable = opts.writable || (opts.writable !== false && stream.writable);
23 var cancelled = false;
24
25 var onlegacyfinish = function() {
26 if (!stream.writable) onfinish();
27 };
28
29 var onfinish = function() {
30 writable = false;
31 if (!readable) callback.call(stream);
32 };
33
34 var onend = function() {
35 readable = false;
36 if (!writable) callback.call(stream);
37 };
38
39 var onexit = function(exitCode) {
40 callback.call(stream, exitCode ? new Error('exited with error code: ' + exitCode) : null);
41 };
42
43 var onerror = function(err) {
44 callback.call(stream, err);
45 };
46
47 var onclose = function() {
48 process.nextTick(onclosenexttick);
49 };
50
51 var onclosenexttick = function() {
52 if (cancelled) return;
53 if (readable && !(rs && (rs.ended && !rs.destroyed))) return callback.call(stream, new Error('premature close'));
54 if (writable && !(ws && (ws.ended && !ws.destroyed))) return callback.call(stream, new Error('premature close'));
55 };
56
57 var onrequest = function() {
58 stream.req.on('finish', onfinish);
59 };
60
61 if (isRequest(stream)) {
62 stream.on('complete', onfinish);
63 stream.on('abort', onclose);
64 if (stream.req) onrequest();
65 else stream.on('request', onrequest);
66 } else if (writable && !ws) { // legacy streams
67 stream.on('end', onlegacyfinish);
68 stream.on('close', onlegacyfinish);
69 }
70
71 if (isChildProcess(stream)) stream.on('exit', onexit);
72
73 stream.on('end', onend);
74 stream.on('finish', onfinish);
75 if (opts.error !== false) stream.on('error', onerror);
76 stream.on('close', onclose);
77
78 return function() {
79 cancelled = true;
80 stream.removeListener('complete', onfinish);
81 stream.removeListener('abort', onclose);
82 stream.removeListener('request', onrequest);
83 if (stream.req) stream.req.removeListener('finish', onfinish);
84 stream.removeListener('end', onlegacyfinish);
85 stream.removeListener('close', onlegacyfinish);
86 stream.removeListener('finish', onfinish);
87 stream.removeListener('exit', onexit);
88 stream.removeListener('end', onend);
89 stream.removeListener('error', onerror);
90 stream.removeListener('close', onclose);
91 };
92};
93
94module.exports = eos;
Note: See TracBrowser for help on using the repository browser.