ExternalVendorCode/openmct
1
0
Fork 0
mirror of https://github.com/nasa/openmct.git synced 2025-01-05 12:54:09 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: revert BatchingWebSocket changes

Browse Source
This commit is contained in:
Jesse Mazzella 2024-04-12 13:23:36 -07:00
parent c0f2d95fa7
commit b597b7530e
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/api/telemetry/BatchingWebSocket.js
View File

@ -19,7 +19,7 @@
* this source code distribution or the Licensing information page available * this source code distribution or the Licensing information page available
* at runtime from the About dialog for additional information. * at runtime from the About dialog for additional information.
*****************************************************************************/ *****************************************************************************/
import installWorker from './WebSocketWorker.js';
/** /**
* Describes the strategy to be used when batching WebSocket messages * Describes the strategy to be used when batching WebSocket messages
* *
@ -69,7 +69,10 @@ class BatchingWebSocket extends EventTarget {
constructor(openmct) { constructor(openmct) {
super(); super();
// Install worker, register listeners etc. // Install worker, register listeners etc.
this.#worker = new Worker(new URL('./WebSocketWorker.js', import.meta.url)); const workerFunction = `(${installWorker.toString()})()`;
const workerBlob = new Blob([workerFunction]);
const workerUrl = URL.createObjectURL(workerBlob, { type: 'application/javascript' });
this.#worker = new Worker(workerUrl);
this.#openmct = openmct; this.#openmct = openmct;
this.#showingRateLimitNotification = false; this.#showingRateLimitNotification = false;
this.#maxBatchSize = Number.POSITIVE_INFINITY; this.#maxBatchSize = Number.POSITIVE_INFINITY;
@ -83,6 +86,7 @@ class BatchingWebSocket extends EventTarget {
'destroy', 'destroy',
() => { () => {
this.disconnect(); this.disconnect();
URL.revokeObjectURL(workerUrl);
}, },
{ once: true } { once: true }
); );