Struct CoreBlockchainRpcClient

pub struct CoreBlockchainRpcClient { /* private fields */ }

Core implementation of a blockchain RPC client that serves as the base for all chain-specific clients.

It provides a shared implementation of common blockchain RPC functionality, handling:

• WebSocket connection management with blockchain RPC node.
• Subscription lifecycle (creation, tracking, and termination).
• Message serialization and deserialization of RPC messages.
• Event type mapping and dispatching.

Implementations

impl CoreBlockchainRpcClient

pub fn new(chain: Chain, wss_rpc_url: String) -> Self

pub async fn connect(&mut self) -> Result<()>

Establishes a WebSocket connection to the blockchain node and sets up the message channel.

Errors

Returns an error if the WebSocket connection fails.

pub async fn wait_on_rpc_channel(&mut self) -> Option<Message>

Waits for and returns the next available message from the WebSocket channel.

pub async fn next_rpc_message( &mut self, ) -> Result<BlockchainMessage, BlockchainRpcClientError>

Retrieves, parses, and returns the next blockchain RPC message as a structured BlockchainRpcMessage type.

Panics

Panics if expected fields (id, result) are missing or cannot be converted when handling subscription confirmations or events.

Errors

Returns an error if the RPC channel encounters an error or if deserialization of the message fails.

pub async fn subscribe_blocks(&mut self) -> Result<(), BlockchainRpcClientError>

Subscribes to real-time block updates from the blockchain node.

Errors

Returns an error if the subscription request fails or if the client is not connected.

pub async fn unsubscribe_blocks( &mut self, ) -> Result<(), BlockchainRpcClientError>

Cancels the subscription to real-time block updates.

Errors

Returns an error if the unsubscription request fails or if the client is not connected.

Trait Implementations

impl Debug for CoreBlockchainRpcClient

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

Formats the value using the given formatter.