Skip to content

Commit e570562

Browse files
committed
chore: update transport to close deviceId last
1 parent b0972bd commit e570562

File tree

3 files changed

+11
-3
lines changed

3 files changed

+11
-3
lines changed

src/transports/base.ts

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,5 +69,13 @@ export abstract class TransportRunnerBase {
6969

7070
abstract start(): Promise<void>;
7171

72-
abstract close(): Promise<void>;
72+
abstract closeTransport(): Promise<void>;
73+
74+
async close(): Promise<void> {
75+
try {
76+
await this.closeTransport();
77+
} finally {
78+
this.deviceId.close();
79+
}
80+
}
7381
}

src/transports/stdio.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ export class StdioRunner extends TransportRunnerBase {
7474
}
7575
}
7676

77-
async close(): Promise<void> {
77+
async closeTransport(): Promise<void> {
7878
await this.server?.close();
7979
}
8080
}

src/transports/streamableHttp.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ export class StreamableHttpRunner extends TransportRunnerBase {
147147
});
148148
}
149149

150-
async close(): Promise<void> {
150+
async closeTransport(): Promise<void> {
151151
await Promise.all([
152152
this.sessionStore.closeAllSessions(),
153153
new Promise<void>((resolve, reject) => {

0 commit comments

Comments
 (0)