OP-2709 Fix subscriptions reconnect (#21)

This commit is contained in:
Dmitry
2022-08-04 13:16:20 +03:00
committed by GitHub
parent 333f7a4e98
commit d38b862f5e

View File

@@ -295,10 +295,12 @@ class OrionAggregatorWS {
this.ws.onopen = () => {
// Re-subscribe to all subscriptions
if (isReconnect) {
Object.keys(this.subscriptions)
const subscriptionsToReconnect = this.subscriptions;
this.subscriptions = {};
Object.keys(subscriptionsToReconnect)
.filter(isSubType)
.forEach((subType) => {
const subscriptions = this.subscriptions[subType];
const subscriptions = subscriptionsToReconnect[subType];
if (subscriptions) {
Object.keys(subscriptions).forEach((subKey) => {
const sub = subscriptions[subKey];