@@ -7,7 +7,7 @@ use alloy::{
7
7
eips:: { BlockId , BlockNumberOrTag :: Latest } ,
8
8
providers:: Provider ,
9
9
} ;
10
- use signet_sim:: { BlockBuild , BuiltBlock , SimCache , SimItem } ;
10
+ use signet_sim:: { BlockBuild , BuiltBlock , SimCache } ;
11
11
use signet_types:: { SlotCalculator , config:: SignetSystemConstants } ;
12
12
use std:: {
13
13
sync:: {
@@ -219,6 +219,7 @@ impl Simulator {
219
219
submit_sender : mpsc:: UnboundedSender < BuiltBlock > ,
220
220
) -> JoinHandle < ( ) > {
221
221
tracing:: debug!( "starting builder task" ) ;
222
+
222
223
tokio:: spawn ( async move { self . run_simulator ( constants, cache, submit_sender) . await } )
223
224
}
224
225
@@ -315,13 +316,13 @@ async fn cache_updater(
315
316
maybe_tx = tx_receiver. recv( ) => {
316
317
if let Some ( tx) = maybe_tx {
317
318
tracing:: debug!( tx = ?tx. hash( ) , "received transaction" ) ;
318
- cache. add_item( SimItem :: Tx ( tx ) , p) ;
319
+ cache. add_item( tx , p) ;
319
320
}
320
321
}
321
322
maybe_bundle = bundle_receiver. recv( ) => {
322
323
if let Some ( bundle) = maybe_bundle {
323
324
tracing:: debug!( bundle = ?bundle. id, "received bundle" ) ;
324
- cache. add_item( SimItem :: Bundle ( bundle. bundle) , p) ;
325
+ cache. add_item( bundle. bundle, p) ;
325
326
}
326
327
}
327
328
}
0 commit comments