summaryrefslogtreecommitdiff
path: root/std/ws/mod.ts
diff options
context:
space:
mode:
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 = {