pub struct PubsubClient { /* private fields */ }Implementations§
Source§impl PubsubClient
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§
Auto Trait Implementations§
impl !Freeze for PubsubClient
impl !RefUnwindSafe for PubsubClient
impl Send for PubsubClient
impl Sync for PubsubClient
impl Unpin for PubsubClient
impl !UnwindSafe for PubsubClient
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 more