| 29103 | if ((cleanup(), 0 === a.listenerCount(this, 'error'))) throw s |
| 29104 | } |
| 29105 | function cleanup() { |
| 29106 | ;(i.removeListener('data', ondata), |
| 29107 | s.removeListener('drain', ondrain), |
| 29108 | i.removeListener('end', onend), |
| 29109 | i.removeListener('close', onclose), |
| 29110 | i.removeListener('error', onerror), |
| 29111 | s.removeListener('error', onerror), |
| 29112 | i.removeListener('end', cleanup), |
| 29113 | i.removeListener('close', cleanup), |
| 29114 | s.removeListener('close', cleanup)) |
| 29115 | } |
| 29116 | return ( |
| 29117 | i.on('error', onerror), |
| 29118 | s.on('error', onerror), |