tornadocontrib/web3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

subscribe instead of watch

Browse Source
This commit is contained in:
Bryan Stitt 2022-04-25 19:46:17 +00:00
parent 969bb32495
commit b16fbf090e
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
examples/watch_blocks.rs → examples/subscribe_blocks.rs
View File

@ -3,12 +3,11 @@ use std::time::Duration;
#[tokio::main] #[tokio::main]
async fn main() -> anyhow::Result<()> { async fn main() -> anyhow::Result<()> {
// let ws = Ws::connect("ws://10.11.12.16:8545").await?; let ws = Ws::connect("ws://10.11.12.16:8545").await?;
let ws = Ws::connect("ws://10.11.12.16:8946").await?; // let ws = Ws::connect("ws://10.11.12.16:8946").await?;
let provider = Provider::new(ws).interval(Duration::from_secs(1)); let provider = Provider::new(ws).interval(Duration::from_secs(1));
let mut stream = provider.watch_blocks().await?.take(5); let mut stream = provider.subscribe_blocks().await?.take(5);
while let Some(block_number) = stream.next().await { while let Some(block) = stream.next().await {
let block = provider.get_block(block_number).await?.unwrap();
println!( println!(
"Ts: {:?}, block number: {} -> {:?}", "Ts: {:?}, block number: {} -> {:?}",
block.timestamp, block.timestamp,