From 50f82c2fd98a655f8569907aac88a9c45e8c71e1 Mon Sep 17 00:00:00 2001
From: sylenien <nikita@openreplay.com>
Date: Fri, 12 Aug 2022 16:17:44 +0200
Subject: [PATCH] fix(player): fix filereader buffer

---
 .../app/player/MessageDistributor/MessageDistributor.ts  | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/frontend/app/player/MessageDistributor/MessageDistributor.ts b/frontend/app/player/MessageDistributor/MessageDistributor.ts
index cd48f54da..2d73081fb 100644
--- a/frontend/app/player/MessageDistributor/MessageDistributor.ts
+++ b/frontend/app/player/MessageDistributor/MessageDistributor.ts
@@ -92,6 +92,7 @@ export default class MessageDistributor extends StatedScreen {
   private readonly lists = initLists();
 
   private activityManager: ActivityManager | null = null;
+  private fileReader: MFileReader;
 
   private sessionStart: number;
   private navigationStartOffset: number = 0;
@@ -151,11 +152,13 @@ export default class MessageDistributor extends StatedScreen {
 
   private readAndDistributeMessages(byteArray: Uint8Array, onReadCb?: (msg: Message) => void) {
     const msgs: Array<Message> = []
-    const reader = new MFileReader(new Uint8Array(), this.sessionStart)
+    if (!this.fileReader) {
+      this.fileReader = new MFileReader(new Uint8Array(), this.sessionStart)
+    }
 
-    reader.append(byteArray)
+    this.fileReader.append(byteArray)
     let next: ReturnType<MFileReader['next']>
-    while (next = reader.next()) {
+    while (next = this.fileReader.next()) {
       const [msg, index] = next
       this.distributeMessage(msg, index)
       msgs.push(msg)