Skip to content

Commit e4f4d18

Browse files
committed
fix: close
1 parent 9f80487 commit e4f4d18

File tree

1 file changed

+12
-10
lines changed

1 file changed

+12
-10
lines changed

src/transports/streamableHttp.ts

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -146,15 +146,17 @@ export class StreamableHttpRunner extends TransportRunnerBase {
146146
}
147147

148148
async close(): Promise<void> {
149-
await new Promise<void>((resolve, reject) => {
150-
this.httpServer?.close((err) => {
151-
if (err) {
152-
reject(err);
153-
return;
154-
}
155-
resolve();
156-
});
157-
});
158-
await this.sessionStore.closeAllSessions();
149+
await Promise.all([
150+
this.sessionStore.closeAllSessions(),
151+
new Promise<void>((resolve, reject) => {
152+
this.httpServer?.close((err) => {
153+
if (err) {
154+
reject(err);
155+
return;
156+
}
157+
resolve();
158+
});
159+
}),
160+
]);
159161
}
160162
}

0 commit comments

Comments
 (0)