diff --git a/cosmos/txpool/handler.go b/cosmos/txpool/handler.go index 7a8e21b26..a357786c0 100644 --- a/cosmos/txpool/handler.go +++ b/cosmos/txpool/handler.go @@ -211,7 +211,6 @@ func (h *handler) stop(err error) { // Close channels. close(h.txsCh) close(h.stopCh) - close(h.stopCh) } // queueTransactions method will propagate a batch of transactions to the CometBFT mempool. diff --git a/cosmos/txpool/handler_test.go b/cosmos/txpool/handler_test.go index 6e31d9585..99cafbf4e 100644 --- a/cosmos/txpool/handler_test.go +++ b/cosmos/txpool/handler_test.go @@ -83,7 +83,6 @@ var _ = Describe("", func() { It("should handle 1 tx", func() { defer GinkgoRecover() serializer.On("ToSdkTxBytes", mock.Anything, mock.Anything).Return([]byte{123}, nil).Once() - broadcaster.On("BroadcastTxSync", []byte{123}).Return(nil, nil).Once() h.txsCh <- core.NewTxsEvent{ Txs: []*coretypes.Transaction{coretypes.NewTx(&coretypes.LegacyTx{Nonce: 5, Gas: 100})}, @@ -93,7 +92,6 @@ var _ = Describe("", func() { It("should handle multiple tx", func() { defer GinkgoRecover() serializer.On("ToSdkTxBytes", mock.Anything, mock.Anything).Return([]byte{123}, nil).Twice() - broadcaster.On("BroadcastTxSync", []byte{123}).Return(nil, nil).Twice() h.txsCh <- core.NewTxsEvent{Txs: []*coretypes.Transaction{ coretypes.NewTx(&coretypes.LegacyTx{Nonce: 5, Gas: 10}),