Trait solana_rpc::rpc_pubsub::RpcSolPubSub

source · [−]
pub trait RpcSolPubSub: Sized + Send + Sync + 'static {
    type Metadata: PubSubMetadata;


Show 19 methods    fn account_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcResponse<UiAccount>>, 
        pubkey_str: String, 
        config: Option<RpcAccountInfoConfig>
    );
    fn account_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: PubSubSubscriptionId
    ) -> Result<bool>;
    fn program_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcResponse<RpcKeyedAccount>>, 
        pubkey_str: String, 
        config: Option<RpcProgramAccountsConfig>
    );
    fn program_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: PubSubSubscriptionId
    ) -> Result<bool>;
    fn logs_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcResponse<RpcLogsResponse>>, 
        filter: RpcTransactionLogsFilter, 
        config: Option<RpcTransactionLogsConfig>
    );
    fn logs_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: PubSubSubscriptionId
    ) -> Result<bool>;
    fn signature_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcResponse<RpcSignatureResult>>, 
        signature_str: String, 
        config: Option<RpcSignatureSubscribeConfig>
    );
    fn signature_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: PubSubSubscriptionId
    ) -> Result<bool>;
    fn slot_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<SlotInfo>
    );
    fn slot_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: PubSubSubscriptionId
    ) -> Result<bool>;
    fn slots_updates_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<Arc<SlotUpdate>>
    );
    fn slots_updates_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: PubSubSubscriptionId
    ) -> Result<bool>;
    fn block_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<Arc<RpcBlockUpdate>>, 
        filter: RpcBlockSubscribeFilter, 
        config: Option<RpcBlockSubscribeConfig>
    );
    fn block_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: PubSubSubscriptionId
    ) -> Result<bool>;
    fn vote_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcVote>
    );
    fn vote_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: PubSubSubscriptionId
    ) -> Result<bool>;
    fn root_subscribe(&self, meta: Self::Metadata, subscriber: Subscriber<Slot>);
    fn root_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: PubSubSubscriptionId
    ) -> Result<bool>;

    fn to_delegate(self) -> IoDelegate<Self, Self::Metadata> { ... }

}

Required Associated Types

Required Methods

Provided Methods

Create an IoDelegate, wiring rpc calls to the trait methods.

Implementors