Struct FutuClient 

pub struct FutuClient { /* private fields */ }

FutuOpenD 高层客户端

功能：

• InitConnect 握手
• 自动心跳 KeepAlive
• 请求-响应匹配（serial number）
• 推送消息分发
• 断线重连

Implementations

impl FutuClient

pub fn new(config: ClientConfig) -> (Self, PushReceiver)

创建客户端（未连接状态）

返回 (client, push_rx)，其中 push_rx 用于接收服务端推送。

pub fn with_init_ai_type(self, ai_type: Option<i32>) -> Self

Set C++ 10.7 InitConnect.C2S.aiType for the next connection.

None preserves the legacy wire shape. C++ treats an absent value as 0 (non-AI); Some(1) marks a skills/AI caller.

pub async fn connect(&mut self) -> Result<InitConnectInfo>

连接到 OpenD 网关并完成 InitConnect 握手

pub async fn request(&self, proto_id: u32, body: Vec<u8>) -> Result<FutuFrame>

发送请求并等待响应

pub async fn request_with_timeout( &self, proto_id: u32, body: Vec<u8>, timeout: Duration, ) -> Result<FutuFrame>

发送请求并等待响应（调用方可指定总请求等待上限）。

与 Self::request 共用同一 pending 清理路径：command channel 入队、 send ack、响应等待任一阶段超时时都必须移除 pending[serial]，避免 调用方自己在外层 tokio::time::timeout 取消 future 时留下悬挂请求。

pub fn conn_id(&self) -> Option<u64>

Server-assigned connection id from InitConnect S2C.

FTAPI trade-write packet ids must echo this value in PacketID.connID; the gateway replay guard compares it against the actual TCP connection.