fix: race condition in rpc unsubscribe
This commit is contained in:
parent
ca34ad2525
commit
d483f7e904
|
@ -1367,7 +1367,7 @@ export class Connection {
|
|||
/**
|
||||
* @private
|
||||
*/
|
||||
async _updateSubscriptions() {
|
||||
_updateSubscriptions() {
|
||||
const accountKeys = Object.keys(this._accountChangeSubscriptions).map(
|
||||
Number,
|
||||
);
|
||||
|
@ -1404,23 +1404,23 @@ export class Connection {
|
|||
}
|
||||
|
||||
for (let id of accountKeys) {
|
||||
const sub: AccountSubscriptionInfo = this._accountChangeSubscriptions[id];
|
||||
await this._subscribe(sub, 'accountSubscribe', [sub.publicKey]);
|
||||
const sub = this._accountChangeSubscriptions[id];
|
||||
this._subscribe(sub, 'accountSubscribe', [sub.publicKey]);
|
||||
}
|
||||
|
||||
for (let id of programKeys) {
|
||||
const sub = this._programAccountChangeSubscriptions[id];
|
||||
await this._subscribe(sub, 'programSubscribe', [sub.programId]);
|
||||
this._subscribe(sub, 'programSubscribe', [sub.programId]);
|
||||
}
|
||||
|
||||
for (let id of slotKeys) {
|
||||
const sub = this._slotSubscriptions[id];
|
||||
await this._subscribe(sub, 'slotSubscribe', []);
|
||||
this._subscribe(sub, 'slotSubscribe', []);
|
||||
}
|
||||
|
||||
for (let id of signatureKeys) {
|
||||
const sub = this._signatureSubscriptions[id];
|
||||
await this._subscribe(sub, 'signatureSubscribe', [sub.signature]);
|
||||
this._subscribe(sub, 'signatureSubscribe', [sub.signature]);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue