Struct KiteTickerAsync 

pub struct KiteTickerAsync { /* private fields */ }

The WebSocket client for connecting to Kite Connect’s streaming quotes service.

Implementations

impl KiteTickerAsync

pub async fn connect(api_key: &str, access_token: &str) -> Result<Self, String>

Establish a connection with the Kite WebSocket server

pub async fn connect_with_options( api_key: &str, access_token: &str, raw_only: bool, ) -> Result<Self, String>

Connect with options

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

Subscribes the client to a list of instruments

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

Close the websocket connection

pub fn is_connected(&self) -> bool

Check if the connection is still alive

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

Send a ping to keep the connection alive

pub fn receiver_count(&self) -> usize

Get the current broadcast channel receiver count

pub fn channel_capacity(&self) -> usize

Get the current broadcast channel capacity

pub fn subscribe_raw(&self) -> Receiver<Arc<[u8]>>

Subscribe to raw binary frames (zero-copy). Each item is an Arc<u8> of the full tungstenite binary frame.

pub fn command_sender(&self) -> Option<UnboundedSender<Message>>

Get a clone of the internal command sender for incremental ops

Trait Implementations

impl Debug for KiteTickerAsync

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

Formats the value using the given formatter.