diff options
author | Andrey Trebler <at@edrilling.no> | 2020-05-08 16:32:09 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-05-08 10:32:09 -0400 |
commit | c42ad381ad64f42e54ea0c1186d81af5abfdbb66 (patch) | |
tree | f086474cf12d1cc357537dc6a0bd92c2fb9f828f /std/ws/mod.ts | |
parent | f9f10229a41d000ae9e96f0907ca321f9ffdeea7 (diff) |
revert PR #5002 (#5141)
Diffstat (limited to 'std/ws/mod.ts')
-rw-r--r-- | std/ws/mod.ts | 27 |
1 files changed, 1 insertions, 26 deletions
diff --git a/std/ws/mod.ts b/std/ws/mod.ts index cec08888b..47353d012 100644 --- a/std/ws/mod.ts +++ b/std/ws/mod.ts @@ -10,10 +10,8 @@ import { TextProtoReader } from "../textproto/mod.ts"; import { Deferred, deferred } from "../util/async.ts"; import { assert } from "../testing/asserts.ts"; import { concat } from "../bytes/mod.ts"; -import { copyBytes } from "../io/util.ts"; import Conn = Deno.Conn; import Writer = Deno.Writer; -import Reader = Deno.Reader; export enum OpCode { Continue = 0x0, @@ -67,10 +65,7 @@ export interface WebSocketFrame { payload: Uint8Array; } -export interface WebSocket - extends Reader, - Writer, - AsyncIterable<WebSocketEvent> { +export interface WebSocket extends AsyncIterable<WebSocketEvent> { readonly conn: Conn; readonly isClosed: boolean; @@ -332,26 +327,6 @@ class WebSocketImpl implements WebSocket { return this.enqueue(frame); } - async write(p: Uint8Array): Promise<number> { - await this.send(p); - - return p.byteLength; - } - - async read(p: Uint8Array): Promise<number | null> { - for await (const ev of this) { - if (ev instanceof Uint8Array) { - return copyBytes(ev, p); - } - - if (typeof ev === "string") { - return copyBytes(encode(ev), p); - } - } - - return null; - } - ping(data: WebSocketMessage = ""): Promise<void> { const payload = typeof data === "string" ? encode(data) : data; const frame = { |