KiteTickerSubscriber

Struct KiteTickerSubscriber 

Source
pub struct KiteTickerSubscriber { /* private fields */ }
Expand description

The Websocket client that entered in a pub/sub mode once the client subscribed to a list of instruments

Implementations§

Source§

impl KiteTickerSubscriber

Source

pub fn get_subscribed(&self) -> Vec<u32>

Get the list of subscribed instruments

Source

pub async fn subscribe( &mut self, tokens: &[u32], mode: Option<Mode>, ) -> Result<(), String>

Subscribe to new tokens

Source

pub async fn set_mode( &mut self, instrument_tokens: &[u32], mode: Mode, ) -> Result<(), String>

Change the mode of the subscribed instrument tokens

Source

pub async fn unsubscribe( &mut self, instrument_tokens: &[u32], ) -> Result<(), String>

Unsubscribe provided subscribed tokens, if input is empty then all subscribed tokens will unsubscribed

Tokens in the input which are not part of the subscribed tokens will be ignored.

Source

pub async fn next_message(&mut self) -> Result<Option<TickerMessage>, String>

Get the next message from the server, waiting if necessary. If the result is None then server is terminated

Source

pub async fn close(&mut self) -> Result<(), String>

Trait Implementations§

Source§

impl Debug for KiteTickerSubscriber

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V