Skip to content

Commit fae79b4

Browse files
committed
👍 入室時に例外が発生したときも後始末する
1 parent fba7f5f commit fae79b4

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

browser/websocket/listen.ts

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -38,12 +38,13 @@ export async function* listenStream(
3838
await connect(socket);
3939
const { request, response } = wrap(socket);
4040

41-
// 部屋に入って購読し始める
42-
await request("socket.io-request", {
43-
method: "room:join",
44-
data: { projectId, pageId: null, projectUpdatesStream: true },
45-
});
4641
try {
42+
// 部屋に入って購読し始める
43+
await request("socket.io-request", {
44+
method: "room:join",
45+
data: { projectId, pageId: null, projectUpdatesStream: true },
46+
});
47+
4748
yield* response(
4849
...events.map((event) => `projectUpdatesStream:${event}` as const),
4950
);

0 commit comments

Comments
 (0)