Skip to content

Commit

Permalink
chore: remove unused variable
Browse files Browse the repository at this point in the history
  • Loading branch information
renlulu committed Sep 27, 2024
1 parent 8230432 commit 923c28e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions arbnode/transaction_streamer.go
Original file line number Diff line number Diff line change
Expand Up @@ -1140,7 +1140,7 @@ func (s *TransactionStreamer) storeResult(

// exposed for testing
// return value: true if should be called again immediately
func (s *TransactionStreamer) ExecuteNextMsg(ctx context.Context, exec execution.ExecutionSequencer) bool {
func (s *TransactionStreamer) ExecuteNextMsg(ctx context.Context) bool {
if ctx.Err() != nil {
return false
}
Expand Down Expand Up @@ -1212,7 +1212,7 @@ func (s *TransactionStreamer) ExecuteNextMsg(ctx context.Context, exec execution
}

func (s *TransactionStreamer) executeMessages(ctx context.Context, ignored struct{}) time.Duration {
if s.ExecuteNextMsg(ctx, s.exec) {
if s.ExecuteNextMsg(ctx) {
return 0
}
return s.config().ExecuteMessageLoopDelay
Expand Down
2 changes: 1 addition & 1 deletion system_tests/eth_sync_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ func TestEthSyncing(t *testing.T) {
if progress == nil {
Fatal(t, "eth_syncing returned nil but shouldn't have")
}
for testClientB.ConsensusNode.TxStreamer.ExecuteNextMsg(ctx, testClientB.ExecNode) {
for testClientB.ConsensusNode.TxStreamer.ExecuteNextMsg(ctx) {
}
progress, err = testClientB.Client.SyncProgress(ctx)
Require(t, err)
Expand Down

0 comments on commit 923c28e

Please sign in to comment.