Struct solana_client::nonblocking::pubsub_client::PubsubClient

pub struct PubsubClient { /* private fields */ }

Implementations

impl PubsubClient

pub async fn new(url: &str) -> PubsubClientResult<Self>

pub async fn shutdown(self) -> PubsubClientResult

pub async fn account_subscribe( &self, pubkey: &Pubkey, config: Option<RpcAccountInfoConfig> ) -> PubsubClientResult<(BoxStream<'_, RpcResponse<UiAccount>>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

pub async fn block_subscribe( &self, filter: RpcBlockSubscribeFilter, config: Option<RpcBlockSubscribeConfig> ) -> PubsubClientResult<(BoxStream<'_, RpcResponse<RpcBlockUpdate>>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

pub async fn logs_subscribe( &self, filter: RpcTransactionLogsFilter, config: RpcTransactionLogsConfig ) -> PubsubClientResult<(BoxStream<'_, RpcResponse<RpcLogsResponse>>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

pub async fn program_subscribe( &self, pubkey: &Pubkey, config: Option<RpcProgramAccountsConfig> ) -> PubsubClientResult<(BoxStream<'_, RpcResponse<RpcKeyedAccount>>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

pub async fn vote_subscribe( &self ) -> PubsubClientResult<(BoxStream<'_, RpcVote>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

pub async fn root_subscribe( &self ) -> PubsubClientResult<(BoxStream<'_, Slot>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

pub async fn signature_subscribe( &self, signature: &Signature, config: Option<RpcSignatureSubscribeConfig> ) -> PubsubClientResult<(BoxStream<'_, RpcResponse<RpcSignatureResult>>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

pub async fn slot_subscribe( &self ) -> PubsubClientResult<(BoxStream<'_, SlotInfo>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

pub async fn slot_updates_subscribe( &self ) -> PubsubClientResult<(BoxStream<'_, SlotUpdate>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

Trait Implementations

impl Debug for PubsubClient

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

Formats the value using the given formatter.