diff --git a/packages/tendermint-rpc/src/tendermint35/tendermint35client.spec.ts b/packages/tendermint-rpc/src/tendermint35/tendermint35client.spec.ts index 96058c40dc..833ec0c37b 100644 --- a/packages/tendermint-rpc/src/tendermint35/tendermint35client.spec.ts +++ b/packages/tendermint-rpc/src/tendermint35/tendermint35client.spec.ts @@ -648,10 +648,6 @@ function websocketTestSuite(rpcFactory: () => RpcClient, expected: ExpectedValue expect(event.header.validatorsHash).toBeTruthy(); events.push(event); - - if (events.length === 3) { - subscription.unsubscribe(); - } }, error: fail, }); @@ -662,6 +658,9 @@ function websocketTestSuite(rpcFactory: () => RpcClient, expected: ExpectedValue // wait for events to be processed await sleep(100); + // Stop listening for new blocks + subscription.unsubscribe(); + // We don't know exactly in which block the transactions are added. So we look into those // with txs. const eventsWithTx = events.filter((e) => e.txs.length > 0);