Method readByChunks

frontend/src/lib/streamReader.ts:69–97

* Process the stream in chunks

(
      callback: (chunk: Uint8Array, bytesProcessed: number) => Promise<void> | void
    )

     * Process the stream in chunks
     */
    async readByChunks(
      callback: (chunk: Uint8Array, bytesProcessed: number) => Promise<void> | void
    ): Promise<number> {
      try {
        while (!this.aborted) {
          const { done, value } = await this.reader.read();
          
          if (done) break;
          
          this.bytesProcessed += value.length;
          
          // Process the chunk
          await callback(value, this.bytesProcessed);
          
          if (this.options.onProgress) {
            this.options.onProgress(this.bytesProcessed);
          }
        }
        
        return this.bytesProcessed;
      } catch (error) {
        if (!this.aborted) {
          console.error('Error reading stream by chunks:', error);
          throw error;
        }
        
        return this.bytesProcessed;
      }
    }
    
    /**
     * Process a text stream line by line (for CSV, etc.)