Reset parser on message size command

vinceau · Nov 11, 2020 · 95302be · 95302be
1 parent aaced99
commit 95302be
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/src/stream/rxSlpStream.ts b/src/stream/rxSlpStream.ts
@@ -57,17 +57,18 @@ export class RxSlpStream extends SlpFileWriter {
 
     this.on(SlpStreamEvent.COMMAND, (data: SlpCommandEventPayload) => {
       const { command, payload } = data;
-      try {
-        this.parser.handleCommand(command, payload);
-      } catch (err) {
-        console.error(`Error processing command ${command}: ${err}`);
-      }
-
       switch (command) {
         case Command.MESSAGE_SIZES:
+          this.parser.reset();
           this.messageSizeSource.next(payload as MessageSizes);
           break;
       }
+
+      try {
+        this.parser.handleCommand(command, payload);
+      } catch (err) {
+        console.error(`Error processing command ${command}: ${err}`);
+      }
     });
   }