fix(bdk_electrum_streaming)!: Give the chain and anchors one owner

bdk_electrum_streaming/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "bdk_electrum_streaming"
-version = "0.5.5"
+version = "0.6.0"
 description = "Experimental but sane BDK electrum client by @evanlinjin."
 license = "MIT OR Apache-2.0"
 edition = "2021"
@@ -13,9 +13,10 @@ readme = "README.md"
 futures = "0.3"
 futures-timer = "3"
 anyhow = "1"
-bdk_core = "0.6"
+bdk_core = { version = "0.6", features = ["serde"] }
 miniscript = { version = "12.0.0" }
 electrum_streaming_client = { version = "0.4" }
+serde = { version = "1", features = ["derive", "rc"] }
 serde_json = "1"
 tracing = "0.1"
 

bdk_electrum_streaming/src/async_client.rs

@@ -1,4 +1,4 @@
-//! Yoo
+//! Driving [`State`](crate::State) over an async transport.
 
 use anyhow::Context;
 use electrum_streaming_client::{
@@ -146,7 +146,7 @@ where
                             );
                         },
                     };
-                    if let Some(update) = state.advance(&mut req_queue, raw)? {
+                    if let Some(update) = state.poll(&mut req_queue, raw)? {
                         update_tx.unbounded_send(update).map_err(|err| anyhow::anyhow!(err.to_string()))?;
                     }
                 }

bdk_electrum_streaming/src/blocking_client.rs

@@ -200,7 +200,7 @@ where
                 };
                 match action {
                     StateAction::FromServer(raw) => {
-                        if let Some(update) = state.advance(&mut req_queue, raw)? {
+                        if let Some(update) = state.poll(&mut req_queue, raw)? {
                             update_tx
                                 .send(update)
                                 .map_err(|err| anyhow::anyhow!(err.to_string()))