summaryrefslogtreecommitdiff
path: root/std/ws/mod.ts
diff options
context:
space:
mode:
authorAndrey Trebler <at@edrilling.no>2020-05-08 16:32:09 +0200
committerGitHub <noreply@github.com>2020-05-08 10:32:09 -0400
commitc42ad381ad64f42e54ea0c1186d81af5abfdbb66 (patch)
treef086474cf12d1cc357537dc6a0bd92c2fb9f828f /std/ws/mod.ts
parentf9f10229a41d000ae9e96f0907ca321f9ffdeea7 (diff)
revert PR #5002 (#5141)
Diffstat (limited to 'std/ws/mod.ts')
-rw-r--r--std/ws/mod.ts27
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 = {