fix

lesleyrs · Jul 10, 2024 · b025637 · b025637
1 parent 15ac63e
commit b025637
Show file tree

Hide file tree

Showing 3 changed files with 18,643 additions and 21,055 deletions.
diff --git a/src/js/jagex2/io/ClientWorkerStream.ts b/src/js/jagex2/io/ClientWorkerStream.ts
@@ -167,12 +167,7 @@ class WorkerReader {
     private async readSlowByte(len: number): Promise<number> {
         this.event = this.queue.removeHead() as WorkerEvent | null;
         while (this.total < len) {
-            await Promise.race([
-                new Promise((resolve): ((value: PromiseLike<((data: WorkerEvent | null) => void) | null>) => void) => (this.callback = resolve)),
-                sleep(100000).then((): void => {
-                    throw new Error('WorkerReader timed out or closed while reading.');
-                })
-            ]);
+            await new Promise((resolve): ((value: PromiseLike<((data: WorkerEvent | null) => void) | null>) => void) => (this.callback = resolve));
         }
         return this.event ? this.event.read : this.readSlowByte(len);
     }