jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: improve beacon api example (#9660)

Browse Source
This commit is contained in:
Matthias Seitz
2024-07-19 21:39:57 +02:00
committed by GitHub
parent 9b057037d9
commit 06eb97c575
1 changed files with 22 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
examples/beacon-api-sidecar-fetcher/src/main.rs
View File

@ -28,7 +28,7 @@ pub mod mined_sidecar;
fn main() {
Cli::<BeaconSidecarConfig>::parse()
.run(|builder, args| async move {
.run(|builder, beacon_config| async move {
// launch the node
let NodeHandle { node, node_exit_future } =
builder.node(EthereumNode::default()).launch().await?;
@ -38,27 +38,30 @@ fn main() {
let pool = node.pool.clone();
let mut sidecar_stream = MinedSidecarStream {
events: notifications,
pool,
beacon_config: args,
client: reqwest::Client::new(),
pending_requests: FuturesUnordered::new(),
queued_actions: VecDeque::new(),
};
node.task_executor.spawn(async move {
let mut sidecar_stream = MinedSidecarStream {
events: notifications,
pool,
beacon_config,
client: reqwest::Client::new(),
pending_requests: FuturesUnordered::new(),
queued_actions: VecDeque::new(),
};
while let Some(result) = sidecar_stream.next().await {
match result {
Ok(blob_transaction) => {
// Handle successful transaction
println!("Processed BlobTransaction: {:?}", blob_transaction);
}
Err(e) => {
// Handle errors specifically
eprintln!("Failed to process transaction: {:?}", e);
while let Some(result) = sidecar_stream.next().await {
match result {
Ok(blob_transaction) => {
// Handle successful transaction
println!("Processed BlobTransaction: {:?}", blob_transaction);
}
Err(e) => {
// Handle errors specifically
eprintln!("Failed to process transaction: {:?}", e);
}
}
}
}
});
node_exit_future.await
})
.unwrap();