Struct AsyncMdApi 

pub struct AsyncMdApi { /* private fields */ }

异步行情API适配器

Implementations

impl AsyncMdApi

pub async fn new( flow_path: Option<&str>, is_using_udp: bool, is_multicast: bool, is_production_mode: Option<bool>, ) -> CtpResult<Self>

创建异步行情API实例

pub async fn register_front(&self, front_address: &str) -> CtpResult<()>

注册前置机地址

pub async fn init(&self) -> CtpResult<()>

初始化API

pub async fn wait_connected(&self, timeout_secs: u64) -> CtpResult<()>

等待连接建立（带超时）

pub async fn login( &self, req: &ReqUserLoginField, timeout_secs: u64, ) -> CtpResult<RspUserLoginField>

异步登录

pub async fn subscribe_market_data( &self, instrument_ids: &[&str], ) -> CtpResult<()>

订阅行情数据

pub async fn unsubscribe_market_data( &self, instrument_ids: &[&str], ) -> CtpResult<()>

取消订阅行情数据

pub async fn recv_event(&self) -> Option<AsyncMdEvent>

接收下一个事件

pub async fn try_recv_event(&self) -> Result<AsyncMdEvent, TryRecvError>

尝试接收事件（非阻塞）

pub async fn get_state(&self) -> AsyncMdState

获取当前状态