Optimised address filter

Author: rg911

src/infrastructure/Listener.ts

@@ -351,9 +351,9 @@ export class Listener implements IListener {
         return this.messageSubject.asObservable().pipe(
             filter((_) => _.channelName === ListenerChannelName.status),
             filter((_) => _.message instanceof TransactionStatusError),
+            filter((_) => _.channelParam.toUpperCase() === address.plain()),
             map((_) => _.message as TransactionStatusError),
             filter((_) => !transactionHash || _.hash.toUpperCase() == transactionHash.toUpperCase()),
-            filter((_) => address.equals(_.address)),
         );
     }
 
@@ -417,6 +417,7 @@ export class Listener implements IListener {
         return this.messageSubject.asObservable().pipe(
             filter((_) => _.channelName.toUpperCase() === ListenerChannelName.cosignature.toUpperCase()),
             filter((_) => _.message instanceof CosignatureSignedTransaction),
+            filter((_) => _.channelParam.toUpperCase() === address.plain()),
             map((_) => _.message as CosignatureSignedTransaction),
         );
     }

test/infrastructure/Listener.spec.ts

@@ -115,7 +115,7 @@ describe('Listener', () => {
             }
 
             const statusInfoErrorDTO = {
-                topic: 'status',
+                topic: `status/${errorAddress.plain()}`,
                 data: {
                     address: errorEncodedAddress,
                     deadline: '1010',
@@ -159,7 +159,7 @@ describe('Listener', () => {
             }
 
             const statusInfoErrorDTO = {
-                topic: 'status',
+                topic: `status/${errorAddress.plain()}`,
                 data: {
                     address: errorEncodedAddress,
                     deadline: '1010',