Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
klkvr committed Nov 25, 2024
1 parent d05239c commit bad1136
Show file tree
Hide file tree
Showing 5 changed files with 8 additions and 14 deletions.
8 changes: 4 additions & 4 deletions book/sources/exex/hello-world/src/bin/3.rs
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
use futures_util::TryStreamExt;
use reth::api::FullNodeComponents;
use reth::{api::FullNodeComponents, primitives::Block, providers::BlockReader};
use reth_exex::{ExExContext, ExExEvent, ExExNotification};
use reth_node_ethereum::EthereumNode;
use reth_tracing::tracing::info;
use reth::providers::BlockReader;
use reth::primitives::Block;

async fn my_exex<Node: FullNodeComponents<Provider: BlockReader<Block = Block>>>(mut ctx: ExExContext<Node>) -> eyre::Result<()> {
async fn my_exex<Node: FullNodeComponents<Provider: BlockReader<Block = Block>>>(
mut ctx: ExExContext<Node>,
) -> eyre::Result<()> {
while let Some(notification) = ctx.notifications.try_next().await? {
match &notification {
ExExNotification::ChainCommitted { new } => {
Expand Down
3 changes: 1 addition & 2 deletions book/sources/exex/remote/src/exex.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ use remote_exex::proto::{
self,
remote_ex_ex_server::{RemoteExEx, RemoteExExServer},
};
use reth::{primitives::Block, providers::BlockReader};
use reth_exex::{ExExContext, ExExEvent, ExExNotification};
use reth_node_api::FullNodeComponents;
use reth_node_ethereum::EthereumNode;
Expand All @@ -11,8 +12,6 @@ use std::sync::Arc;
use tokio::sync::{broadcast, mpsc};
use tokio_stream::wrappers::ReceiverStream;
use tonic::{transport::Server, Request, Response, Status};
use reth::providers::BlockReader;
use reth::primitives::Block;

struct ExExService {
notifications: Arc<broadcast::Sender<ExExNotification>>,
Expand Down
3 changes: 1 addition & 2 deletions book/sources/exex/remote/src/exex_4.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ use remote_exex::proto::{
self,
remote_ex_ex_server::{RemoteExEx, RemoteExExServer},
};
use reth::{primitives::Block, providers::BlockReader};
use reth_exex::{ExExContext, ExExEvent, ExExNotification};
use reth_node_api::FullNodeComponents;
use reth_node_ethereum::EthereumNode;
Expand All @@ -11,8 +12,6 @@ use std::sync::Arc;
use tokio::sync::{broadcast, mpsc};
use tokio_stream::wrappers::ReceiverStream;
use tonic::{transport::Server, Request, Response, Status};
use reth::providers::BlockReader;
use reth::primitives::Block;

struct ExExService {
notifications: Arc<broadcast::Sender<ExExNotification>>,
Expand Down
4 changes: 1 addition & 3 deletions book/sources/exex/tracking-state/src/bin/1.rs
Original file line number Diff line number Diff line change
Expand Up @@ -5,12 +5,10 @@ use std::{
};

use futures_util::{FutureExt, TryStreamExt};
use reth::api::FullNodeComponents;
use reth::{api::FullNodeComponents, primitives::Block, providers::BlockReader};
use reth_exex::{ExExContext, ExExEvent, ExExNotification};
use reth_node_ethereum::EthereumNode;
use reth_tracing::tracing::info;
use reth::providers::BlockReader;
use reth::primitives::Block;

struct MyExEx<Node: FullNodeComponents> {
ctx: ExExContext<Node>,
Expand Down
4 changes: 1 addition & 3 deletions book/sources/exex/tracking-state/src/bin/2.rs
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,10 @@ use std::{

use alloy_primitives::BlockNumber;
use futures_util::{FutureExt, TryStreamExt};
use reth::api::FullNodeComponents;
use reth::{api::FullNodeComponents, primitives::Block, providers::BlockReader};
use reth_exex::{ExExContext, ExExEvent};
use reth_node_ethereum::EthereumNode;
use reth_tracing::tracing::info;
use reth::providers::BlockReader;
use reth::primitives::Block;

struct MyExEx<Node: FullNodeComponents> {
ctx: ExExContext<Node>,
Expand Down

0 comments on commit bad1136

Please sign in to comment.