summaryrefslogtreecommitdiff
path: root/ext
diff options
context:
space:
mode:
Diffstat (limited to 'ext')
-rw-r--r--ext/websocket/02_websocketstream.js20
1 files changed, 10 insertions, 10 deletions
diff --git a/ext/websocket/02_websocketstream.js b/ext/websocket/02_websocketstream.js
index f4f866c6b..d4c960338 100644
--- a/ext/websocket/02_websocketstream.js
+++ b/ext/websocket/02_websocketstream.js
@@ -82,7 +82,7 @@ const CLOSE_RESPONSE_TIMEOUT = 5000;
const _rid = Symbol("[[rid]]");
const _url = Symbol("[[url]]");
-const _connection = Symbol("[[connection]]");
+const _opened = Symbol("[[opened]]");
const _closed = Symbol("[[closed]]");
const _earlyClose = Symbol("[[earlyClose]]");
const _closeSent = Symbol("[[closeSent]]");
@@ -155,7 +155,7 @@ class WebSocketStream {
if (options.signal?.aborted) {
core.close(cancelRid);
const err = options.signal.reason;
- this[_connection].reject(err);
+ this[_opened].reject(err);
this[_closed].reject(err);
} else {
const abort = () => {
@@ -192,7 +192,7 @@ class WebSocketStream {
"Closed while connecting",
"NetworkError",
);
- this[_connection].reject(err);
+ this[_opened].reject(err);
this[_closed].reject(err);
},
);
@@ -202,7 +202,7 @@ class WebSocketStream {
"Closed while connecting",
"NetworkError",
);
- this[_connection].reject(err);
+ this[_opened].reject(err);
this[_closed].reject(err);
},
);
@@ -334,7 +334,7 @@ class WebSocketStream {
},
});
- this[_connection].resolve({
+ this[_opened].resolve({
readable,
writable,
extensions: create.extensions ?? "",
@@ -349,17 +349,17 @@ class WebSocketStream {
} else {
core.tryClose(cancelRid);
}
- this[_connection].reject(err);
+ this[_opened].reject(err);
this[_closed].reject(err);
},
);
}
}
- [_connection] = new Deferred();
- get connection() {
+ [_opened] = new Deferred();
+ get opened() {
webidl.assertBranded(this, WebSocketStreamPrototype);
- return this[_connection].promise;
+ return this[_opened].promise;
}
[_earlyClose] = false;
@@ -405,7 +405,7 @@ class WebSocketStream {
code = 1000;
}
- if (this[_connection].state === "pending") {
+ if (this[_opened].state === "pending") {
this[_earlyClose] = true;
} else if (this[_closed].state === "pending") {
PromisePrototypeThen(