summaryrefslogtreecommitdiff
path: root/std/ws
diff options
context:
space:
mode:
Diffstat (limited to 'std/ws')
-rw-r--r--std/ws/mod.ts4
-rw-r--r--std/ws/test.ts12
2 files changed, 8 insertions, 8 deletions
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<void> {
+ send(data: WebSocketMessage): Promise<void> {
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<void> {
+ ping(data: WebSocketMessage = ""): Promise<void> {
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<number | Deno.EOF> {
- return Deno.EOF;
+ read(_: Uint8Array): Promise<number | Deno.EOF> {
+ 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<number | Deno.EOF> {
- return Deno.EOF;
+ read(_: Uint8Array): Promise<number | Deno.EOF> {
+ 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<number> {
+ write(_: Uint8Array): Promise<number> {
return new Promise(resolve => {
timer = setTimeout(() => resolve(0), 1000);
});