update book

paradigmxyz · Sep 3, 2024 · 689e538 · 689e538
1 parent 83cfcc1
commit 689e538
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/book/developers/exex/hello-world.md b/book/developers/exex/hello-world.md
@@ -107,8 +107,8 @@ use reth_node_ethereum::EthereumNode;
 use reth_tracing::tracing::info;
 
 async fn my_exex<Node: FullNodeComponents>(mut ctx: ExExContext<Node>) -> eyre::Result<()> {
-    let notifications = ctx.notifications.subscribe(); 
-    while let Some(notification) = notifications.recv().await {
+    let mut notifications = ctx.notifications.subscribe(); 
+    while let Some(notification) = notifications.next().await {
         match &notification {
             ExExNotification::ChainCommitted { new } => {
                 info!(committed_chain = ?new.range(), "Received commit");

diff --git a/book/developers/exex/tracking-state.md b/book/developers/exex/tracking-state.md
@@ -50,7 +50,7 @@ impl<Node: FullNodeComponents> Future for MyExEx<Node> {
     fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         let this = self.get_mut();
 
-        while let Some(notification) = ready!(this.notifications.poll_recv(cx)) {
+        while let Some(notification) = ready!(this.notifications.poll_next_unpin(cx)) {
             match &notification {
                 ExExNotification::ChainCommitted { new } => {
                     info!(committed_chain = ?new.range(), "Received commit");