From a4f023d2502dcaefc79850d3f7d94655202e11c1 Mon Sep 17 00:00:00 2001 From: Dessalines Date: Thu, 2 Dec 2021 09:59:31 -0500 Subject: [PATCH] Fix issue with websocket buffer. --- src/shared/services/WebSocketService.ts | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/shared/services/WebSocketService.ts b/src/shared/services/WebSocketService.ts index 85a1af8..ea5d3f6 100644 --- a/src/shared/services/WebSocketService.ts +++ b/src/shared/services/WebSocketService.ts @@ -3,6 +3,7 @@ import { Observable } from "rxjs"; import { share } from "rxjs/operators"; import { ExponentialBackoff, + LRUBuffer, Websocket as WS, WebsocketBuilder, } from "websocket-ts"; @@ -47,6 +48,7 @@ export class WebSocketService { console.error("Websocket closed."); }) .withBackoff(new ExponentialBackoff(100, 7)) + .withBuffer(new LRUBuffer(1000)) .build(); }).pipe(share()); -- 2.44.1