Skip to content
This repository has been archived by the owner on Jun 9, 2024. It is now read-only.

Commit

Permalink
unit tests passing
Browse files Browse the repository at this point in the history
  • Loading branch information
ocnc committed Oct 25, 2023
1 parent f259b6f commit b5a4141
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 3 deletions.
1 change: 0 additions & 1 deletion cosmos/txpool/handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
2 changes: 0 additions & 2 deletions cosmos/txpool/handler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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})},
Expand All @@ -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}),
Expand Down

0 comments on commit b5a4141

Please sign in to comment.