Struct Request

pub struct Request { /* private fields */ }

Websocket request structure

Implementations

impl Request

pub fn subscribe(instrument_tokens: Vec<u32>) -> Request

Subscribe to a list of instrument tokens

Examples found in repository

examples/mode_test.rs (line 11)

fn main() {
  println!("🔍 KiteTicker Mode Serialization Test");
  println!("═══════════════════════════════════════");

  // Test different subscription requests to verify JSON format
  let tokens = vec![256265, 265, 256777];

  // 1. Test subscribe request
  let subscribe_req = Request::subscribe(tokens.clone());
  println!("📡 Subscribe request JSON:");
  println!("{}", subscribe_req);
  println!();

  // 2. Test unsubscribe request
  let unsubscribe_req = Request::unsubscribe(tokens.clone());
  println!("📡 Unsubscribe request JSON:");
  println!("{}", unsubscribe_req);
  println!();

  // 3. Test mode requests with different modes
  let modes = [Mode::LTP, Mode::Quote, Mode::Full];
  let mode_names = ["LTP", "Quote", "Full"];

  for (mode, name) in modes.iter().zip(mode_names.iter()) {
    let mode_req = Request::mode(*mode, tokens.clone());
    println!(
      "🎯 Mode request for {} ({}): JSON:",
      name,
      mode.to_websocket_string()
    );
    println!("{}", mode_req);
    println!();
  }

  // 4. Test individual mode string conversion
  println!("🔧 Mode to WebSocket string conversion:");
  for (mode, name) in modes.iter().zip(mode_names.iter()) {
    println!("   {} -> \"{}\"", name, mode.to_websocket_string());
  }

  println!("✅ All mode serialization tests completed!");
}

pub fn mode(mode: Mode, instrument_tokens: Vec<u32>) -> Request

Subscribe to a list of instrument tokens with mode

Examples found in repository

examples/mode_test.rs (line 27)

fn main() {
  println!("🔍 KiteTicker Mode Serialization Test");
  println!("═══════════════════════════════════════");

  // Test different subscription requests to verify JSON format
  let tokens = vec![256265, 265, 256777];

  // 1. Test subscribe request
  let subscribe_req = Request::subscribe(tokens.clone());
  println!("📡 Subscribe request JSON:");
  println!("{}", subscribe_req);
  println!();

  // 2. Test unsubscribe request
  let unsubscribe_req = Request::unsubscribe(tokens.clone());
  println!("📡 Unsubscribe request JSON:");
  println!("{}", unsubscribe_req);
  println!();

  // 3. Test mode requests with different modes
  let modes = [Mode::LTP, Mode::Quote, Mode::Full];
  let mode_names = ["LTP", "Quote", "Full"];

  for (mode, name) in modes.iter().zip(mode_names.iter()) {
    let mode_req = Request::mode(*mode, tokens.clone());
    println!(
      "🎯 Mode request for {} ({}): JSON:",
      name,
      mode.to_websocket_string()
    );
    println!("{}", mode_req);
    println!();
  }

  // 4. Test individual mode string conversion
  println!("🔧 Mode to WebSocket string conversion:");
  for (mode, name) in modes.iter().zip(mode_names.iter()) {
    println!("   {} -> \"{}\"", name, mode.to_websocket_string());
  }

  println!("✅ All mode serialization tests completed!");
}

pub fn unsubscribe(instrument_tokens: Vec<u32>) -> Request

Unsubscribe from a list of instrument tokens

Examples found in repository

examples/mode_test.rs (line 17)

fn main() {
  println!("🔍 KiteTicker Mode Serialization Test");
  println!("═══════════════════════════════════════");

  // Test different subscription requests to verify JSON format
  let tokens = vec![256265, 265, 256777];

  // 1. Test subscribe request
  let subscribe_req = Request::subscribe(tokens.clone());
  println!("📡 Subscribe request JSON:");
  println!("{}", subscribe_req);
  println!();

  // 2. Test unsubscribe request
  let unsubscribe_req = Request::unsubscribe(tokens.clone());
  println!("📡 Unsubscribe request JSON:");
  println!("{}", unsubscribe_req);
  println!();

  // 3. Test mode requests with different modes
  let modes = [Mode::LTP, Mode::Quote, Mode::Full];
  let mode_names = ["LTP", "Quote", "Full"];

  for (mode, name) in modes.iter().zip(mode_names.iter()) {
    let mode_req = Request::mode(*mode, tokens.clone());
    println!(
      "🎯 Mode request for {} ({}): JSON:",
      name,
      mode.to_websocket_string()
    );
    println!("{}", mode_req);
    println!();
  }

  // 4. Test individual mode string conversion
  println!("🔧 Mode to WebSocket string conversion:");
  for (mode, name) in modes.iter().zip(mode_names.iter()) {
    println!("   {} -> \"{}\"", name, mode.to_websocket_string());
  }

  println!("✅ All mode serialization tests completed!");
}

Trait Implementations

impl Clone for Request

fn clone(&self) -> Request

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Request

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Request

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for Request

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

Formats the value using the given formatter.

impl Serialize for Request

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.