Skip to content

Commit 6cfc4f1

Browse files
test: debug
1 parent 48a021b commit 6cfc4f1

1 file changed

Lines changed: 11 additions & 7 deletions

File tree

src/index.js

Lines changed: 11 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -644,13 +644,13 @@ function honoWrapper(compiler, options, usePlugin) {
644644
/**
645645
* @param {Error=} err err
646646
*/
647-
const done = (err) => {
647+
const onEvent = (err) => {
648648
if (isResolved) return;
649649
isResolved = true;
650650

651-
stream.removeListener("error", done);
652-
stream.removeListener("readable", done);
653-
stream.removeListener("end", done);
651+
stream.removeListener("error", onEvent);
652+
stream.removeListener("readable", onEvent);
653+
stream.removeListener("end", onEvent);
654654

655655
if (err) {
656656
stream.destroy();
@@ -663,10 +663,14 @@ function honoWrapper(compiler, options, usePlugin) {
663663
resolve();
664664
};
665665

666-
stream.once("error", done);
667-
stream.once("readable", done);
666+
stream.once("error", onEvent);
667+
stream.once("readable", onEvent);
668668
// Empty stream
669-
stream.once("end", done);
669+
stream.once("end", onEvent);
670+
671+
if (stream.pending === false) {
672+
onEvent();
673+
}
670674
};
671675

672676
/**

0 commit comments

Comments
 (0)