Skip to content

Commit 5219695

Browse files
petersirkapetersirka
committed
Added fallback for prependListener (for older version of Node.js).
1 parent 9c38051 commit 5219695

1 file changed

Lines changed: 20 additions & 7 deletions

File tree

‎internal.js‎

Lines changed: 20 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -3169,16 +3169,29 @@ function onFinished(stream, fn) {
31693169
if (stream.socket) {
31703170
if (!stream.socket.$totalstream) {
31713171
stream.socket.$totalstream = stream;
3172-
stream.socket.prependListener('error', callback);
3173-
stream.socket.prependListener('close', callback);
3172+
if (stream.socket.prependListener) {
3173+
stream.socket.prependListener('error', callback);
3174+
stream.socket.prependListener('close', callback);
3175+
} else {
3176+
stream.socket.on('error', callback);
3177+
stream.socket.on('close', callback);
3178+
}
31743179
}
31753180
}
31763181

3177-
stream.prependListener('error', callback);
3178-
stream.prependListener('end', callback);
3179-
stream.prependListener('close', callback);
3180-
stream.prependListener('aborted', callback);
3181-
stream.prependListener('finish', callback);
3182+
if (stream.prependListener) {
3183+
stream.prependListener('error', callback);
3184+
stream.prependListener('end', callback);
3185+
stream.prependListener('close', callback);
3186+
stream.prependListener('aborted', callback);
3187+
stream.prependListener('finish', callback);
3188+
} else {
3189+
stream.on('error', callback);
3190+
stream.on('end', callback);
3191+
stream.on('close', callback);
3192+
stream.on('aborted', callback);
3193+
stream.on('finish', callback);
3194+
}
31823195

31833196
//stream.uri --> determines ServerRespone
31843197
// stream.uri && stream.prependListener('aborted', callback);

0 commit comments

Comments
 (0)