Struct solana_rpc::rpc_pubsub::RpcSolPubSubImpl
source · pub struct RpcSolPubSubImpl { /* private fields */ }
Implementations§
source§impl RpcSolPubSubImpl
impl RpcSolPubSubImpl
pub fn new( config: PubSubConfig, subscription_control: SubscriptionControl, current_subscriptions: Arc<DashMap<SubscriptionId, SubscriptionToken>>, ) -> Self
Trait Implementations§
source§impl RpcSolPubSubInternal for RpcSolPubSubImpl
impl RpcSolPubSubInternal for RpcSolPubSubImpl
fn account_subscribe( &self, pubkey_str: String, config: Option<RpcAccountInfoConfig>, ) -> Result<SubscriptionId>
fn account_unsubscribe(&self, id: SubscriptionId) -> Result<bool>
fn program_subscribe( &self, pubkey_str: String, config: Option<RpcProgramAccountsConfig>, ) -> Result<SubscriptionId>
fn program_unsubscribe(&self, id: SubscriptionId) -> Result<bool>
fn logs_subscribe( &self, filter: RpcTransactionLogsFilter, config: Option<RpcTransactionLogsConfig>, ) -> Result<SubscriptionId>
fn logs_unsubscribe(&self, id: SubscriptionId) -> Result<bool>
fn signature_subscribe( &self, signature_str: String, config: Option<RpcSignatureSubscribeConfig>, ) -> Result<SubscriptionId>
fn signature_unsubscribe(&self, id: SubscriptionId) -> Result<bool>
fn slot_subscribe(&self) -> Result<SubscriptionId>
fn slot_unsubscribe(&self, id: SubscriptionId) -> Result<bool>
fn slots_updates_subscribe(&self) -> Result<SubscriptionId>
fn slots_updates_unsubscribe(&self, id: SubscriptionId) -> Result<bool>
fn block_subscribe( &self, filter: RpcBlockSubscribeFilter, config: Option<RpcBlockSubscribeConfig>, ) -> Result<SubscriptionId>
fn block_unsubscribe(&self, id: SubscriptionId) -> Result<bool>
fn vote_subscribe(&self) -> Result<SubscriptionId>
fn vote_unsubscribe(&self, id: SubscriptionId) -> Result<bool>
fn root_subscribe(&self) -> Result<SubscriptionId>
fn root_unsubscribe(&self, id: SubscriptionId) -> Result<bool>
fn get_version(&self) -> Result<RpcVersionInfo>
source§fn to_delegate<M: Metadata>(self) -> IoDelegate<Self, M>
fn to_delegate<M: Metadata>(self) -> IoDelegate<Self, M>
Create an
IoDelegate
, wiring rpc calls to the trait methods.Auto Trait Implementations§
impl Freeze for RpcSolPubSubImpl
impl !RefUnwindSafe for RpcSolPubSubImpl
impl Send for RpcSolPubSubImpl
impl Sync for RpcSolPubSubImpl
impl Unpin for RpcSolPubSubImpl
impl !UnwindSafe for RpcSolPubSubImpl
Blanket Implementations§
source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request