fix: Fix the problem that balance not right if switch network from de…

…fault network

Change WalletCreatedSubject from ReplaySubject to Subject, when switch network from default network, WalletCreatedSubject will start subscribe and replay the old created event which happend in default network, so two queue will started and balance will be incorrect

packages/neuron-wallet/src/models/subjects/wallet-created-subject.ts

@@ -1,13 +1,13 @@
-import { ReplaySubject } from 'rxjs'
+import { Subject } from 'rxjs'
 
 export class WalletCreatedSubject {
-  static subject = new ReplaySubject<string>(1)
+  static subject = new Subject<string>()
 
   static getSubject() {
     return this.subject
   }
 
-  static setSubject(subject: ReplaySubject<string>) {
+  static setSubject(subject: Subject<string>) {
     this.subject = subject
   }
 }

packages/neuron-wallet/src/startup/sync-block-task/create.ts

@@ -10,7 +10,7 @@ import DataUpdateSubject from 'models/subjects/data-update'
 import logger from 'utils/logger'
 import NodeService from 'services/node'
 import NetworksService from 'services/networks'
-import { distinctUntilChanged } from 'rxjs/operators'
+import { distinctUntilChanged, pairwise, startWith } from 'rxjs/operators'
 import LockUtils from 'models/lock-utils'
 import DaoUtils from 'models/dao-utils'
 import NetworkSwitchSubject from 'models/subjects/network-switch-subject'
@@ -59,11 +59,17 @@ const networkChange = async (network: NetworkWithID) => {
 
 export const databaseInitSubject = new ReplaySubject<DatabaseInitParams>(1)
 
-NetworkSwitchSubject.getSubject().subscribe(async (network: NetworkWithID | undefined) => {
-  if (network) {
-    await networkChange(network)
-  }
-})
+NetworkSwitchSubject
+  .getSubject()
+  .pipe(
+    startWith(undefined),
+    pairwise()
+  )
+  .subscribe(async ([previousNetwork, network]: (NetworkWithID | undefined)[]) => {
+    if ((!previousNetwork && network) || (previousNetwork && network && network.id !== previousNetwork.id)) {
+      await networkChange(network)
+    }
+  })
 
 NodeService
   .getInstance()