kiteticker-async-manager 0.4.0

High-performance async WebSocket client for Kite Connect API with multi-connection support, dynamic subscription management, and optimized data processing.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use serde_repr::{Deserialize_repr, Serialize_repr};

#[derive(
  Debug,
  Clone,
  Copy,
  Deserialize_repr,
  Serialize_repr,
  Default,
  PartialEq,
  PartialOrd,
)]
#[repr(u8)]
///
/// Modes in which packets are streamed
///
pub enum Mode {
  LTP = 1,
  #[default]
  Quote = 2,
  Full = 3,
}

impl Mode {
  /// Convert Mode to WebSocket command string
  pub fn to_websocket_string(&self) -> &'static str {
    match self {
      Mode::LTP => "ltp",
      Mode::Quote => "quote",
      Mode::Full => "full",
    }
  }
}

impl TryFrom<usize> for Mode {
  type Error = String;
  fn try_from(value: usize) -> Result<Self, Self::Error> {
    match value {
      8 => Ok(Self::LTP),
      44 => Ok(Self::Quote),
      184 => Ok(Self::Full),
      _ => Err(format!("Invalid packet size: {}", value)),
    }
  }
}