(readable, unpipeInfo)
| 948 | |
| 949 | dest.on('unpipe', onunpipe); |
| 950 | function onunpipe(readable, unpipeInfo) { |
| 951 | debug('onunpipe'); |
| 952 | if (readable === src) { |
| 953 | if (unpipeInfo && unpipeInfo.hasUnpiped === false) { |
| 954 | unpipeInfo.hasUnpiped = true; |
| 955 | cleanup(); |
| 956 | } |
| 957 | } |
| 958 | } |
| 959 | |
| 960 | function onend() { |
| 961 | debug('onend'); |