fix: update for Uint8Array being generic

Author: dsherret

body.ts

@@ -30,13 +30,13 @@ const KNOWN_BODY_TYPES: [bodyType: BodyType, knownMediaTypes: string[]][] = [
 ];
 
 async function readBlob(
-  body?: ReadableStream<Uint8Array> | null,
+  body?: ReadableStream<Uint8Array<ArrayBuffer>> | null,
   type?: string | null,
 ): Promise<Blob> {
   if (!body) {
     return new Blob(undefined, type ? { type } : undefined);
   }
-  const chunks: Uint8Array[] = [];
+  const chunks: Uint8Array<ArrayBuffer>[] = [];
   for await (const chunk of body) {
     chunks.push(chunk);
   }
@@ -45,7 +45,7 @@ async function readBlob(
 
 /** An object which encapsulates information around a request body. */
 export class Body {
-  #body?: ReadableStream<Uint8Array> | null;
+  #body?: ReadableStream<Uint8Array<ArrayBuffer>> | null;
   #memo: Promise<ArrayBuffer | Blob | FormData | string> | null = null;
   #memoType: "arrayBuffer" | "blob" | "formData" | "text" | null = null;
   #headers?: Headers;
@@ -80,7 +80,7 @@ export class Body {
   }
 
   /** Exposes the "raw" `ReadableStream` of the body. */
-  get stream(): ReadableStream<Uint8Array> | null {
+  get stream(): ReadableStream<Uint8Array<ArrayBuffer>> | null {
     return this.#request ? this.#request.body : this.#body!;
   }
 

http_server_bun.ts

@@ -94,7 +94,7 @@ class BunRequest implements ServerRequest {
   #resolved = false;
   #promise: Promise<Response>;
 
-  get body(): ReadableStream<Uint8Array> | null {
+  get body(): ReadableStream<Uint8Array<ArrayBuffer>> | null {
     return this.#request.body;
   }
 
@@ -150,7 +150,7 @@ class BunRequest implements ServerRequest {
     this.#reject(reason);
   }
 
-  getBody(): ReadableStream<Uint8Array> | null {
+  getBody(): ReadableStream<Uint8Array<ArrayBuffer>> | null {
     return this.#request.body;
   }
 

http_server_native_request.ts

@@ -55,7 +55,7 @@ export class NativeRequest implements ServerRequest {
     this.#response = promise;
   }
 
-  get body(): ReadableStream<Uint8Array> | null {
+  get body(): ReadableStream<Uint8Array<ArrayBuffer>> | null {
     return this.#request.body;
   }
 
@@ -102,7 +102,7 @@ export class NativeRequest implements ServerRequest {
     this.#resolved = true;
   }
 
-  getBody(): ReadableStream<Uint8Array> | null {
+  getBody(): ReadableStream<Uint8Array<ArrayBuffer>> | null {
     return this.#request.body;
   }
 

http_server_node.ts

@@ -90,15 +90,15 @@ export class NodeRequest implements ServerRequest {
     this.#responded = true;
   }
 
-  getBody(): ReadableStream<Uint8Array> | null {
-    let body: ReadableStream<Uint8Array> | null;
+  getBody(): ReadableStream<Uint8Array<ArrayBuffer>> | null {
+    let body: ReadableStream<Uint8Array<ArrayBuffer>> | null;
     if (this.method === "GET" || this.method === "HEAD") {
       body = null;
     } else {
-      body = new ReadableStream<Uint8Array>({
+      body = new ReadableStream<Uint8Array<ArrayBuffer>>({
         start: (controller) => {
-          this.#request.on("data", (chunk: Uint8Array) => {
-            controller.enqueue(chunk);
+          this.#request.on("data", (chunk) => {
+            controller.enqueue(chunk as Uint8Array<ArrayBuffer>);
           });
           this.#request.on("error", (err: Error) => {
             controller.error(err);

send.ts

@@ -137,9 +137,9 @@ async function getEntity(
   stats: Deno.FileInfo,
   maxbuffer: number,
   response: Response,
-): Promise<[Uint8Array | Deno.FsFile, Uint8Array | FileInfo, FileInfo]> {
-  let body: Uint8Array | Deno.FsFile;
-  let entity: Uint8Array | FileInfo;
+): Promise<[Uint8Array<ArrayBuffer> | Deno.FsFile, Uint8Array<ArrayBuffer> | FileInfo, FileInfo]> {
+  let body: Uint8Array<ArrayBuffer> | Deno.FsFile;
+  let entity: Uint8Array<ArrayBuffer> | FileInfo;
   const fileInfo = { mtime: new Date(mtime), size: stats.size };
   if (stats.size < maxbuffer) {
     const buffer = await Deno.readFile(path);
@@ -270,8 +270,8 @@ export async function send(
       : contentTypes[extname(path)] ?? extname(path);
   }
 
-  let entity: Uint8Array | FileInfo | null = null;
-  let body: Uint8Array | Deno.FsFile | null = null;
+  let entity: Uint8Array<ArrayBuffer> | FileInfo | null = null;
+  let body: Uint8Array<ArrayBuffer> | Deno.FsFile | null = null;
   let fileInfo: FileInfo | null = null;
 
   if (request.headers.has("If-None-Match") && mtime) {

types.ts

@@ -21,7 +21,7 @@ export interface ServerRequest {
   readonly url: string;
   // deno-lint-ignore no-explicit-any
   error(reason?: any): void;
-  getBody(): ReadableStream<Uint8Array> | null;
+  getBody(): ReadableStream<Uint8Array<ArrayBuffer>> | null;
   respond(response: Response): void | Promise<void>;
   upgrade?(options?: UpgradeWebSocketOptions): WebSocket;
 }
@@ -38,8 +38,8 @@ export interface ServerConstructor<T extends ServerRequest> {
   type?: "native" | "node" | "bun";
 }
 
-export type Data = string | number[] | ArrayBuffer | Uint8Array;
-export type Key = string | number[] | ArrayBuffer | Uint8Array;
+export type Data = string | number[] | ArrayBuffer | Uint8Array<ArrayBuffer>;
+export type Key = string | number[] | ArrayBuffer | Uint8Array<ArrayBuffer>;
 
 export interface UpgradeWebSocketOptions {
   protocol?: string;