... blocks.
let sub = provider.subscribe_blocks().await?;
// Wait and take the next 4 blocks.
let mut stream = sub.into_stream().take(4);
// let mut stream = sub.into_stream();
println!("Awaiting block headers...");
// Take the stream and print the block number upon ...