Struct QuoteSubscription 

pub struct QuoteSubscription { /* private fields */ }

Quote 订阅

Implementations

impl QuoteSubscription

pub fn new( dm: Arc<DataManager>, ws: Arc<TqQuoteWebsocket>, initial_symbols: Vec<String>, ) -> Self

创建新的 Quote 订阅

pub async fn start(&self) -> Result<()>

启动订阅监听

pub async fn add_symbols(&self, symbols: &[&str]) -> Result<()>

添加合约

pub async fn remove_symbols(&self, symbols: &[&str]) -> Result<()>

移除合约

pub fn quote_channel(&self) -> Receiver<Quote>

获取 Quote 更新通道（克隆接收端）

pub async fn on_quote<F>(&self, handler: F)

where F: Fn(Arc<Quote>) + Send + Sync + 'static,

注册回调

pub async fn on_error<F>(&self, handler: F)

where F: Fn(Arc<String>) + Send + Sync + 'static,

注册错误回调

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

关闭订阅