Struct chainseeker_server::zeromq::ZeroMQClient

pub struct ZeroMQClient { /* fields omitted */ }

Listens to the Bitcoin Core’s ZeroMQ server and relay messages to other threads.

Implementations

impl ZeroMQClient

pub fn new(zmq_endpoint: &str) -> Self

pub async fn run(&self, sender: Sender<ZeroMQMessage>)

pub async fn start(&self) -> Receiver<ZeroMQMessage>

pub async fn is_ready(&self) -> bool

pub async fn wait_for_ready(&self)

pub async fn is_stopped(&self) -> bool

pub async fn stop(&self)

pub async fn wait_for_stop(&self)

Trait Implementations

impl Clone for ZeroMQClient

fn clone(&self) -> ZeroMQClient

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ZeroMQClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.