We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4039cb5 commit b1dfc26Copy full SHA for b1dfc26
benches/suites/streams/stream_1KiB.ts
@@ -30,6 +30,8 @@ async function main() {
30
},
31
logger: logger.getChild('QUICServer'),
32
});
33
+ const { p: serverStreamEndedP, resolveP: serverStreamEndedResolveP } =
34
+ utils.promise<void>();
35
quicServer.addEventListener(
36
events.EventQUICServerConnection.name,
37
(evt: events.EventQUICServerConnection) => {
@@ -43,6 +45,7 @@ async function main() {
43
45
for await (const _ of stream.readable) {
44
46
// Do nothing, only consume
47
}
48
+ serverStreamEndedResolveP();
49
50
);
51
@@ -75,6 +78,7 @@ async function main() {
75
78
...suiteCommon,
76
79
77
80
await writer.close();
81
+ await serverStreamEndedP;
82
await quicClient?.destroy();
83
await quicServer?.stop();
84
return summary;
0 commit comments