| 19919 | ;((a.pipesCount += 1), j('pipe count=%d opts=%j', a.pipesCount, o)) |
| 19920 | var w = (!o || !1 !== o.end) && s !== u.stdout && s !== u.stderr ? onend : unpipe |
| 19921 | function onunpipe(o, u) { |
| 19922 | ;(j('onunpipe'), |
| 19923 | o === i && |
| 19924 | u && |
| 19925 | !1 === u.hasUnpiped && |
| 19926 | ((u.hasUnpiped = !0), |
| 19927 | (function cleanup() { |
| 19928 | ;(j('cleanup'), |
| 19929 | s.removeListener('close', onclose), |
| 19930 | s.removeListener('finish', onfinish), |
| 19931 | s.removeListener('drain', x), |
| 19932 | s.removeListener('error', onerror), |
| 19933 | s.removeListener('unpipe', onunpipe), |
| 19934 | i.removeListener('end', onend), |
| 19935 | i.removeListener('end', unpipe), |
| 19936 | i.removeListener('data', ondata), |
| 19937 | (C = !0), |
| 19938 | !a.awaitDrain || (s._writableState && !s._writableState.needDrain) || x()) |
| 19939 | })())) |
| 19940 | } |
| 19941 | function onend() { |
| 19942 | ;(j('onend'), s.end()) |
| 19943 | } |