tweak: no future txs in stream.

blocknative · Dec 6, 2023 · c53379e · c53379e
1 parent bda0b19
commit c53379e
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/eth/filters/trace_api.go b/eth/filters/trace_api.go
@@ -48,10 +48,6 @@ func (api *FilterAPI) NewPendingTransactionsWithTrace(ctx context.Context, trace
 		pendingTxSub := api.events.SubscribePendingTxs(pendingTxs)
 		defer pendingTxSub.Unsubscribe()
 
-		futureTxs := make(chan []*types.Transaction, 128)
-		futureTxSub := api.events.SubscribeFutureTxs(futureTxs)
-		defer futureTxSub.Unsubscribe()
-
 		tracerOpts, err := getTracerOpts(tracerOptsJSON, defaultTxTraceOpts)
 		if err != nil {
 			log.Error("pending_txs_stream: failed to parse tracer options", "err", err)
@@ -77,8 +73,6 @@ func (api *FilterAPI) NewPendingTransactionsWithTrace(ctx context.Context, trace
 			select {
 			case txs = <-pendingTxs:
 				txsAreFuture = false
-			case txs = <-futureTxs:
-				txsAreFuture = true
 			case <-rpcSub.Err():
 				return
 			case <-notifier.Closed():