1 files changed, 14 insertions, 13 deletions

diff --git a/std/ws/mod.ts b/std/ws/mod.ts
index e2151a53e..5f0219cfc 100644
--- a/std/ws/mod.ts
+++ b/std/ws/mod.ts
@@ -32,7 +32,7 @@ export interface WebSocketCloseEvent {
 }
 
 export function isWebSocketCloseEvent(
-  a: WebSocketEvent
+  a: WebSocketEvent,
 ): a is WebSocketCloseEvent {
   return hasOwnProperty(a, "code");
 }
@@ -40,7 +40,7 @@ export function isWebSocketCloseEvent(
 export type WebSocketPingEvent = ["ping", Uint8Array];
 
 export function isWebSocketPingEvent(
-  a: WebSocketEvent
+  a: WebSocketEvent,
 ): a is WebSocketPingEvent {
   return Array.isArray(a) && a[0] === "ping" && a[1] instanceof Uint8Array;
 }
@@ -48,7 +48,7 @@ export function isWebSocketPingEvent(
 export type WebSocketPongEvent = ["pong", Uint8Array];
 
 export function isWebSocketPongEvent(
-  a: WebSocketEvent
+  a: WebSocketEvent,
 ): a is WebSocketPongEvent {
   return Array.isArray(a) && a[0] === "pong" && a[1] instanceof Uint8Array;
 }
@@ -105,14 +105,14 @@ export function unmask(payload: Uint8Array, mask?: Uint8Array): void {
 /** Write websocket frame to given writer */
 export async function writeFrame(
   frame: WebSocketFrame,
-  writer: Deno.Writer
+  writer: Deno.Writer,
 ): Promise<void> {
   const payloadLength = frame.payload.byteLength;
   let header: Uint8Array;
   const hasMask = frame.mask ? 0x80 : 0;
   if (frame.mask && frame.mask.byteLength !== 4) {
     throw new Error(
-      "invalid mask. mask must be 4 bytes: length=" + frame.mask.byteLength
+      "invalid mask. mask must be 4 bytes: length=" + frame.mask.byteLength,
     );
   }
   if (payloadLength < 126) {
@@ -263,7 +263,7 @@ class WebSocketImpl implements WebSocket {
           // [0x12, 0x34] -> 0x1234
           const code = (frame.payload[0] << 8) | frame.payload[1];
           const reason = decode(
-            frame.payload.subarray(2, frame.payload.length)
+            frame.payload.subarray(2, frame.payload.length),
           );
           await this.close(code, reason);
           yield { code, reason };
@@ -312,8 +312,9 @@ class WebSocketImpl implements WebSocket {
   }
 
   send(data: WebSocketMessage): Promise<void> {
-    const opcode =
-      typeof data === "string" ? OpCode.TextFrame : OpCode.BinaryFrame;
+    const opcode = typeof data === "string"
+      ? OpCode.TextFrame
+      : OpCode.BinaryFrame;
     const payload = typeof data === "string" ? encode(data) : data;
     const isLastFrame = true;
     const frame = {
@@ -382,7 +383,7 @@ class WebSocketImpl implements WebSocket {
       this.sendQueue = [];
       rest.forEach((e) =>
         e.d.reject(
-          new Deno.errors.ConnectionReset("Socket has already been closed")
+          new Deno.errors.ConnectionReset("Socket has already been closed"),
         )
       );
     }
@@ -457,7 +458,7 @@ export async function handshake(
   url: URL,
   headers: Headers,
   bufReader: BufReader,
-  bufWriter: BufWriter
+  bufWriter: BufWriter,
 ): Promise<void> {
   const { hostname, pathname, search } = url;
   const key = createSecKey();
@@ -494,7 +495,7 @@ export async function handshake(
   if (version !== "HTTP/1.1" || statusCode !== "101") {
     throw new Error(
       `ws: server didn't accept handshake: ` +
-        `version=${version}, statusCode=${statusCode}`
+        `version=${version}, statusCode=${statusCode}`,
     );
   }
 
@@ -508,7 +509,7 @@ export async function handshake(
   if (secAccept !== expectedSecAccept) {
     throw new Error(
       `ws: unexpected sec-websocket-accept header: ` +
-        `expected=${expectedSecAccept}, actual=${secAccept}`
+        `expected=${expectedSecAccept}, actual=${secAccept}`,
     );
   }
 }
@@ -519,7 +520,7 @@ export async function handshake(
  */
 export async function connectWebSocket(
   endpoint: string,
-  headers: Headers = new Headers()
+  headers: Headers = new Headers(),
 ): Promise<WebSocket> {
   const url = new URL(endpoint);
   const { hostname } = url;