mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-17 06:12:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove streamError emits

Browse Source
This commit is contained in:
Ciro Spaciari
2024-05-21 11:35:33 -03:00
parent b2b7ad235e
commit 4d7ea6c1b6
1 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/js/node/http2.ts
View File

@@ -663,7 +663,6 @@ function emitStreamErrorNT(self, streams, streamId, error, destroy) {
stream.emit("error", error_instance);
if (destroy) stream.destroy(error_instance);
}
self.emit("streamError", error_instance);
}
function emitAbortedNT(self, streams, streamId, error) {
@@ -678,7 +677,6 @@ function emitAbortedNT(self, streams, streamId, error) {
stream.emit("aborted", error);
stream.emit("error", error_instance);
}
self.emit("streamError", error_instance);
}
class ClientHttp2Session extends Http2Session {
/// close indicates that we called closed
@@ -726,7 +724,6 @@ class ClientHttp2Session extends Http2Session {
}
stream.rstCode = error;
stream.emit("error", error_instance);
self.emit("streamError", error_instance);
} else {
process.nextTick(emitStreamErrorNT, self, self.#streams, streamId, error);
}
@@ -842,7 +839,6 @@ class ClientHttp2Session extends Http2Session {
stream.rstCode = constants.NGHTTP2_CANCEL;
stream.emit("aborted", error);
stream.emit("error", error_instance);
self.emit("streamError", error_instance);
} else {
process.nextTick(emitAbortedNT, self, self.#streams, streamId, error);
}