machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix subscription management in address component

Browse Source
This commit is contained in:
natsoni 2024-04-09 14:11:57 +09:00
parent b74b8a8a5a
commit cfc06be975
No known key found for this signature in database
GPG Key ID: C65917583181743B
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
frontend/src/app/components/address/address.component.ts
View File

@ -28,6 +28,9 @@ export class AddressComponent implements OnInit, OnDestroy {
retryLoadMore = false; retryLoadMore = false;
error: any; error: any;
mainSubscription: Subscription; mainSubscription: Subscription;
mempoolTxSubscription: Subscription;
mempoolRemovedTxSubscription: Subscription;
blockTxSubscription: Subscription;
addressLoadingStatus$: Observable<number>; addressLoadingStatus$: Observable<number>;
addressInfo: null | AddressInformation = null; addressInfo: null | AddressInformation = null;
@ -179,17 +182,17 @@ export class AddressComponent implements OnInit, OnDestroy {
this.isLoadingAddress = false; this.isLoadingAddress = false;
}); });
this.stateService.mempoolTransactions$ this.mempoolTxSubscription = this.stateService.mempoolTransactions$
.subscribe(tx => { .subscribe(tx => {
this.addTransaction(tx); this.addTransaction(tx);
}); });
this.stateService.mempoolRemovedTransactions$ this.mempoolRemovedTxSubscription = this.stateService.mempoolRemovedTransactions$
.subscribe(tx => { .subscribe(tx => {
this.removeTransaction(tx); this.removeTransaction(tx);
}); });
this.stateService.blockTransactions$ this.blockTxSubscription = this.stateService.blockTransactions$
.subscribe((transaction) => { .subscribe((transaction) => {
const tx = this.transactions.find((t) => t.txid === transaction.txid); const tx = this.transactions.find((t) => t.txid === transaction.txid);
if (tx) { if (tx) {
@ -295,6 +298,9 @@ export class AddressComponent implements OnInit, OnDestroy {
ngOnDestroy() { ngOnDestroy() {
this.mainSubscription.unsubscribe(); this.mainSubscription.unsubscribe();
this.mempoolTxSubscription.unsubscribe();
this.mempoolRemovedTxSubscription.unsubscribe();
this.blockTxSubscription.unsubscribe();
this.websocketService.stopTrackingAddress(); this.websocketService.stopTrackingAddress();
} }
} }