This crate provides a relatively thin wrapper around Bitcoin ZMQ, allowing for the construction of asynchronous streams of transaction or block data.
Requirements
sudo apt install pkg-config libzmq3-dev
Usage
usebitcoin_zmq::ZMQListener;usefutures::prelude::*;#[tokio::main]
async fnmain(){// Construct ZMQ listenr
let listener =ZMQListener::bind("tcp://127.0.0.1:28332").await
.expect("could not connect");// Do something with stream of messages
listener
.stream().take(10).try_for_each(move|raw|{println!("raw message: {:?}",hex::encode(raw));future::ok(())}).await
.expect("zmq error'd during stream");}