Suite of AT Protocol TypeScript libraries built on web standards
chore: fmt
+4
-5
+4
-5
xrpc-server/stream/websocket-keepalive.ts
+4
-5
xrpc-server/stream/websocket-keepalive.ts
···
1
-
import { type ClientOptions, WebSocket, createWebSocketStream } from "ws";
1
+
import { type ClientOptions, createWebSocketStream, WebSocket } from "ws";
2
2
import { isErrnoException, SECOND, wait } from "@atp/common";
3
3
import { CloseCode, DisconnectError } from "./types.ts";
4
4
···
62
62
yield chunk;
63
63
}
64
64
} catch (_err) {
65
-
const err =
66
-
isErrnoException(_err) && _err.code === "ABORT_ERR"
67
-
? _err.cause
68
-
: _err;
65
+
const err = isErrnoException(_err) && _err.code === "ABORT_ERR"
66
+
? _err.cause
67
+
: _err;
69
68
if (err instanceof DisconnectError) {
70
69
this.ws?.close(err.wsCode);
71
70
break;