Struct solana_rpc::rpc_pubsub::RpcSolPubSubImpl
source · [−]pub struct RpcSolPubSubImpl { /* private fields */ }
Implementations
sourceimpl RpcSolPubSubImpl
impl RpcSolPubSubImpl
pub fn new(
config: PubSubConfig,
subscription_control: SubscriptionControl,
current_subscriptions: Arc<DashMap<SubscriptionId, SubscriptionToken>>
) -> Self
Trait Implementations
sourceimpl 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>
sourcefn 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 !RefUnwindSafe for RpcSolPubSubImpl
impl Send for RpcSolPubSubImpl
impl Sync for RpcSolPubSubImpl
impl Unpin for RpcSolPubSubImpl
impl !UnwindSafe for RpcSolPubSubImpl
Blanket Implementations
impl<T> AbiExample for T
impl<T> AbiExample for T
default fn example() -> T
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
impl<T> Pointable for T
impl<T> Pointable for T
impl<T> TupleTree<T, ()> for T
impl<T> TupleTree<T, ()> for T
const SIZE: Size = Size{degree: 0, descendants: 0,}
fn descendants(_indirect_level: usize) -> usize
fn height() -> usize
fn preorder(self, f: &mut impl FnMut(Visit<T>))
fn preorder_with_size_hint(self, f: &mut impl FnMut(Visit<T>, Size))
fn postorder(self, f: &mut impl FnMut(Visit<T>))
fn postorder_with_size_hint(self, f: &mut impl FnMut(Visit<T>, Size))
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more