fix: better code

Author: astandrik

src/services/api/streaming.ts

@@ -85,7 +85,7 @@ export class StreamingAPI extends BaseYdbAPI {
                 if (done) {
                     break;
                 }
-                streamParser.processChunk(value);
+                streamParser.processBuffer(value);
             }
         } finally {
             reader.releaseLock();

src/services/parsers/parseMultipartStream.ts

@@ -84,17 +84,13 @@ export class MultipartStreamParser {
         this.bufferPos = 0;
     }
 
-    processChunk(chunk: Uint8Array): void {
+    processBuffer(chunk: Uint8Array): void {
         // Append new data to buffer
         const newBuffer = new Uint8Array(this.buffer.length + chunk.length);
         newBuffer.set(this.buffer);
         newBuffer.set(chunk, this.buffer.length);
         this.buffer = newBuffer;
 
-        this.processBuffer();
-    }
-
-    private processBuffer(): void {
         while (this.bufferPos < this.buffer.length) {
             const boundaryPos = arrayIndexOf(this.buffer, this.boundaryBytes, this.bufferPos);
             if (boundaryPos === -1) {

src/store/reducers/query/query.ts

@@ -259,7 +259,7 @@ interface QueryStats {
     endTime?: string | number;
 }
 
-const DEFAULT_STREAM_CHUNK_SIZE = 100;
+const DEFAULT_STREAM_CHUNK_SIZE = 2;
 const DEFAULT_CONCURRENT_RESULTS = false;
 
 export const queryApi = api.injectEndpoints({