Skip to main content

BlockchainRpcClient

nautilus_blockchain::rpc

Trait BlockchainRpcClient 

Source 
pub trait BlockchainRpcClient {
    // Required methods
    fn connect<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn subscribe_blocks<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<(), BlockchainRpcClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn subscribe_pool_events<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        event_type: RpcEventType,
        addresses: &'life1 [Address],
        event_signature: String,
    ) -> Pin<Box<dyn Future<Output = Result<(), BlockchainRpcClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn unsubscribe_blocks<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<(), BlockchainRpcClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn next_rpc_message<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<BlockchainMessage, BlockchainRpcClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn set_transport_backend(&mut self, backend: TransportBackend);
    fn set_socket_control(&mut self, control: SocketControl);
}

Required Methods§

Source

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn subscribe_blocks<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), BlockchainRpcClientError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn subscribe_pool_events<'life0, 'life1, 'async_trait>( &'life0 mut self, event_type: RpcEventType, addresses: &'life1 [Address], event_signature: String, ) -> Pin<Box<dyn Future<Output = Result<(), BlockchainRpcClientError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source

fn unsubscribe_blocks<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), BlockchainRpcClientError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn next_rpc_message<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<BlockchainMessage, BlockchainRpcClientError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn set_transport_backend(&mut self, backend: TransportBackend)

Source

fn set_socket_control(&mut self, control: SocketControl)

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§