Editorial: rename internal slots for brevity

reference-implementation/lib/ReadableByteStreamController-impl.js

@@ -33,7 +33,7 @@ exports.implementation = class ReadableByteStreamControllerImpl {
       throw new TypeError('The stream has already been closed; do not close it again!');
     }
 
-    const state = this._controlledReadableStream._state;
+    const state = this._stream._state;
     if (state !== 'readable') {
       throw new TypeError(`The stream (in ${state} state) is not in the readable state and cannot be closed`);
     }
@@ -53,7 +53,7 @@ exports.implementation = class ReadableByteStreamControllerImpl {
       throw new TypeError('stream is closed or draining');
     }
 
-    const state = this._controlledReadableStream._state;
+    const state = this._stream._state;
     if (state !== 'readable') {
       throw new TypeError(`The stream (in ${state} state) is not in the readable state and cannot be enqueued to`);
     }
@@ -79,7 +79,7 @@ exports.implementation = class ReadableByteStreamControllerImpl {
   }
 
   [PullSteps](readRequest) {
-    const stream = this._controlledReadableStream;
+    const stream = this._stream;
     assert(aos.ReadableStreamHasDefaultReader(stream) === true);
 
     if (this._queueTotalSize > 0) {

reference-implementation/lib/ReadableStream-impl.js

@@ -119,7 +119,7 @@ exports.implementation = class ReadableStreamImpl {
 
   [idlUtils.asyncIteratorNext](iterator) {
     const reader = iterator._reader;
-    if (reader._ownerReadableStream === undefined) {
+    if (reader._stream === undefined) {
       return promiseRejectedWith(
         new TypeError('Cannot get the next iteration result once the reader has been released')
       );
@@ -143,7 +143,7 @@ exports.implementation = class ReadableStreamImpl {
 
   [idlUtils.asyncIteratorReturn](iterator, arg) {
     const reader = iterator._reader;
-    if (reader._ownerReadableStream === undefined) {
+    if (reader._stream === undefined) {
       return promiseResolvedWith(undefined);
     }
 

reference-implementation/lib/ReadableStreamBYOBReader-impl.js

@@ -13,7 +13,7 @@ exports.implementation = class ReadableStreamBYOBReaderImpl {
   }
 
   cancel(reason) {
-    if (this._ownerReadableStream === undefined) {
+    if (this._stream === undefined) {
       return promiseRejectedWith(readerLockException('cancel'));
     }
 
@@ -28,7 +28,7 @@ exports.implementation = class ReadableStreamBYOBReaderImpl {
       return promiseRejectedWith(new TypeError('view\'s buffer must have non-zero byteLength'));
     }
 
-    if (this._ownerReadableStream === undefined) {
+    if (this._stream === undefined) {
       return promiseRejectedWith(readerLockException('read'));
     }
 
@@ -43,7 +43,7 @@ exports.implementation = class ReadableStreamBYOBReaderImpl {
   }
 
   releaseLock() {
-    if (this._ownerReadableStream === undefined) {
+    if (this._stream === undefined) {
       return;
     }
 

reference-implementation/lib/ReadableStreamDefaultController-impl.js

@@ -37,7 +37,7 @@ exports.implementation = class ReadableStreamDefaultControllerImpl {
   }
 
   [PullSteps](readRequest) {
-    const stream = this._controlledReadableStream;
+    const stream = this._stream;
 
     if (this._queue.length > 0) {
       const chunk = DequeueValue(this);

reference-implementation/lib/ReadableStreamDefaultReader-impl.js

@@ -13,15 +13,15 @@ exports.implementation = class ReadableStreamDefaultReaderImpl {
   }
 
   cancel(reason) {
-    if (this._ownerReadableStream === undefined) {
+    if (this._stream === undefined) {
       return promiseRejectedWith(readerLockException('cancel'));
     }
 
     return aos.ReadableStreamReaderGenericCancel(this, reason);
   }
 
   read() {
-    if (this._ownerReadableStream === undefined) {
+    if (this._stream === undefined) {
       return promiseRejectedWith(readerLockException('read from'));
     }
 
@@ -37,7 +37,7 @@ exports.implementation = class ReadableStreamDefaultReaderImpl {
   }
 
   releaseLock() {
-    if (this._ownerReadableStream === undefined) {
+    if (this._stream === undefined) {
       return;
     }
 

reference-implementation/lib/TransformStream-impl.js

@@ -32,7 +32,7 @@ exports.implementation = class TransformStreamImpl {
     aos.SetUpTransformStreamDefaultControllerFromTransformer(this, transformer, transformerDict);
 
     if ('start' in transformerDict) {
-      resolvePromise(startPromise, transformerDict.start.call(transformer, this._transformStreamController));
+      resolvePromise(startPromise, transformerDict.start.call(transformer, this._controller));
     } else {
       resolvePromise(startPromise, undefined);
     }

reference-implementation/lib/TransformStreamDefaultController-impl.js

@@ -5,7 +5,7 @@ const rsAOs = require('./abstract-ops/readable-streams.js');
 
 exports.implementation = class TransformStreamDefaultController {
   get desiredSize() {
-    const readableController = this._controlledTransformStream._readable._readableStreamController;
+    const readableController = this._stream._readable._controller;
     return rsAOs.ReadableStreamDefaultControllerGetDesiredSize(readableController);
   }
 

reference-implementation/lib/WritableStreamDefaultController-impl.js

@@ -6,7 +6,7 @@ const { ResetQueue } = require('./abstract-ops/queue-with-sizes.js');
 
 exports.implementation = class WritableStreamDefaultControllerImpl {
   error(e) {
-    const state = this._controlledWritableStream._state;
+    const state = this._stream._state;
 
     if (state !== 'writable') {
       // The stream is closed, errored or will be soon. The sink can't do anything useful if it gets an error here, so

reference-implementation/lib/WritableStreamDefaultWriter-impl.js

@@ -14,7 +14,7 @@ exports.implementation = class WritableStreamDefaultWriterImpl {
   }
 
   get desiredSize() {
-    if (this._ownerWritableStream === undefined) {
+    if (this._stream === undefined) {
       throw defaultWriterLockException('desiredSize');
     }
 
@@ -26,15 +26,15 @@ exports.implementation = class WritableStreamDefaultWriterImpl {
   }
 
   abort(reason) {
-    if (this._ownerWritableStream === undefined) {
+    if (this._stream === undefined) {
       return promiseRejectedWith(defaultWriterLockException('abort'));
     }
 
     return aos.WritableStreamDefaultWriterAbort(this, reason);
   }
 
   close() {
-    const stream = this._ownerWritableStream;
+    const stream = this._stream;
 
     if (stream === undefined) {
       return promiseRejectedWith(defaultWriterLockException('close'));
@@ -48,7 +48,7 @@ exports.implementation = class WritableStreamDefaultWriterImpl {
   }
 
   releaseLock() {
-    const stream = this._ownerWritableStream;
+    const stream = this._stream;
 
     if (stream === undefined) {
       return;
@@ -60,7 +60,7 @@ exports.implementation = class WritableStreamDefaultWriterImpl {
   }
 
   write(chunk) {
-    if (this._ownerWritableStream === undefined) {
+    if (this._stream === undefined) {
       return promiseRejectedWith(defaultWriterLockException('write to'));
     }