refactor(streams): prepare for noUncheckedIndexedAccess (#4377)

denoland · Feb 24, 2024 · 271a100 · 271a100
1 parent 58cb4ba
commit 271a100
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 9 deletions.
diff --git a/streams/_common.ts b/streams/_common.ts
@@ -20,7 +20,7 @@ export function createLPS(pat: Uint8Array): Uint8Array {
       lps[i] = 0;
       i++;
     } else {
-      prefixEnd = lps[prefixEnd - 1];
+      prefixEnd = lps[prefixEnd - 1]!;
     }
   }
   return lps;

diff --git a/streams/delimiter_stream.ts b/streams/delimiter_stream.ts
@@ -116,7 +116,7 @@ export class DelimiterStream extends TransformStream<Uint8Array, Uint8Array> {
             // they are (with concatenation).
             if (bufs.length === 1) {
               // Concat not needed when a single buffer is passed.
-              controller.enqueue(bufs[0]);
+              controller.enqueue(bufs[0]!);
             } else {
               controller.enqueue(concat(bufs));
             }
@@ -134,7 +134,7 @@ export class DelimiterStream extends TransformStream<Uint8Array, Uint8Array> {
           } else if (delimitedChunkEnd < 0 && bufs.length > 0) {
             // Our chunk started by finishing a partial delimiter match.
             const lastIndex = bufs.length - 1;
-            const last = bufs[lastIndex];
+            const last = bufs[lastIndex]!;
             const lastSliceIndex = last.byteLength + delimitedChunkEnd;
             const lastSliced = last.subarray(0, lastSliceIndex);
             if (lastIndex === 0) {
@@ -173,7 +173,7 @@ export class DelimiterStream extends TransformStream<Uint8Array, Uint8Array> {
         // but now got a new 'A', then we'll drop down to having matched
         // just 'A'. The while loop will turn around again and we'll rematch
         // to 'AA' and proceed onwards to try and match on 'B' again.
-        matchIndex = lps[matchIndex - 1];
+        matchIndex = lps[matchIndex - 1]!;
       }
     }
     // Save match index.
@@ -231,7 +231,7 @@ export class DelimiterStream extends TransformStream<Uint8Array, Uint8Array> {
           // they are (with concatenation).
           if (bufs.length === 1) {
             // Concat not needed when a single buffer is passed.
-            controller.enqueue(bufs[0]);
+            controller.enqueue(bufs[0]!);
           } else {
             controller.enqueue(concat(bufs));
           }
@@ -275,7 +275,7 @@ export class DelimiterStream extends TransformStream<Uint8Array, Uint8Array> {
     if (length === 0) {
       controller.enqueue(new Uint8Array());
     } else if (length === 1) {
-      controller.enqueue(bufs[0]);
+      controller.enqueue(bufs[0]!);
     } else {
       controller.enqueue(concat(bufs));
     }

diff --git a/streams/merge_readable_streams.ts b/streams/merge_readable_streams.ts
@@ -40,9 +40,9 @@ export function mergeReadableStreams<T>(
               }
               controller.enqueue(data);
             }
-            resolvePromises[index].resolve();
+            resolvePromises[index]!.resolve();
           } catch (error) {
-            resolvePromises[index].reject(error);
+            resolvePromises[index]!.reject(error);
           }
         })();
       }

diff --git a/streams/text_delimiter_stream.ts b/streams/text_delimiter_stream.ts
@@ -73,7 +73,7 @@ export class TextDelimiterStream extends TransformStream<string, string> {
           this.#inspectIndex++;
           localIndex++;
         } else {
-          this.#matchIndex = this.#delimLPS[this.#matchIndex - 1];
+          this.#matchIndex = this.#delimLPS[this.#matchIndex - 1]!;
         }
       }
     }