From 798904b0f2ed0c7284b67bba2f125f406b5850de Mon Sep 17 00:00:00 2001 From: Samrith Shankar Date: Fri, 20 Mar 2020 14:38:34 +0100 Subject: Add require-await lint rule (#4401) --- std/ws/mod.ts | 4 ++-- std/ws/test.ts | 12 ++++++------ 2 files changed, 8 insertions(+), 8 deletions(-) (limited to 'std/ws') diff --git a/std/ws/mod.ts b/std/ws/mod.ts index 809654a06..3332ed8dd 100644 --- a/std/ws/mod.ts +++ b/std/ws/mod.ts @@ -322,7 +322,7 @@ class WebSocketImpl implements WebSocket { return d; } - async send(data: WebSocketMessage): Promise { + send(data: WebSocketMessage): Promise { const opcode = typeof data === "string" ? OpCode.TextFrame : OpCode.BinaryFrame; const payload = typeof data === "string" ? encode(data) : data; @@ -336,7 +336,7 @@ class WebSocketImpl implements WebSocket { return this.enqueue(frame); } - async ping(data: WebSocketMessage = ""): Promise { + ping(data: WebSocketMessage = ""): Promise { const payload = typeof data === "string" ? encode(data) : data; const frame = { isLastFrame: true, diff --git a/std/ws/test.ts b/std/ws/test.ts index 820fe1423..f1efa8e40 100644 --- a/std/ws/test.ts +++ b/std/ws/test.ts @@ -126,7 +126,7 @@ test("[ws] read unmasked bigger binary frame", async () => { assertEquals(bin.payload.length, payloadLength); }); -test("[ws] createSecAccept", async () => { +test("[ws] createSecAccept", () => { const nonce = "dGhlIHNhbXBsZSBub25jZQ=="; const d = createSecAccept(nonce); assertEquals(d, "s3pPLMBiTxaQ9kYGzzhZRbK+xOo="); @@ -335,8 +335,8 @@ test("[ws] createSecKeyHasCorrectLength", () => { test("[ws] WebSocket should throw `Deno.errors.ConnectionReset` when peer closed connection without close frame", async () => { const buf = new Buffer(); const eofReader: Deno.Reader = { - async read(_: Uint8Array): Promise { - return Deno.EOF; + read(_: Uint8Array): Promise { + return Promise.resolve(Deno.EOF); } }; const conn = dummyConn(eofReader, buf); @@ -353,8 +353,8 @@ test("[ws] WebSocket should throw `Deno.errors.ConnectionReset` when peer closed test("[ws] WebSocket shouldn't throw `Deno.errors.UnexpectedEof` on recive()", async () => { const buf = new Buffer(); const eofReader: Deno.Reader = { - async read(_: Uint8Array): Promise { - return Deno.EOF; + read(_: Uint8Array): Promise { + return Promise.resolve(Deno.EOF); } }; const conn = dummyConn(eofReader, buf); @@ -372,7 +372,7 @@ test({ const buf = new Buffer(); let timer: number | undefined; const lazyWriter: Deno.Writer = { - async write(_: Uint8Array): Promise { + write(_: Uint8Array): Promise { return new Promise(resolve => { timer = setTimeout(() => resolve(0), 1000); }); -- cgit v1.2.3