Struct WsBroadcaster 

pub struct WsBroadcaster { /* private fields */ }

WebSocket 推送广播器

OpenD 核心推送事件 → broadcast channel → 所有 WebSocket 客户端

实现 ExternalPushSink trait，可直接嵌入 PushDispatcher。

Implementations

impl WsBroadcaster

pub fn new(capacity: usize) -> Self

pub fn send(&self, event: WsPushEvent)

发送推送事件到所有 WebSocket 客户端

pub fn subscribe(&self) -> Receiver<WsPushEvent>

创建接收端

pub fn push_quote( &self, sec_key: &str, sub_type: i32, proto_id: u32, body: &[u8], )

发送行情推送

pub fn push_broadcast(&self, proto_id: u32, body: &[u8])

发送广播推送

pub fn push_trade(&self, acc_id: u64, proto_id: u32, body: &[u8])

发送交易推送

Trait Implementations

impl Clone for WsBroadcaster

fn clone(&self) -> WsBroadcaster

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ExternalPushSink for WsBroadcaster

实现 ExternalPushSink，使 WsBroadcaster 可嵌入 PushDispatcher

fn on_quote_push( &self, sec_key: &str, sub_type: i32, proto_id: u32, body: &[u8], )

行情推送

fn on_broadcast_push(&self, proto_id: u32, body: &[u8])

广播推送 (到价提醒、系统通知等)

fn on_trade_push(&self, acc_id: u64, proto_id: u32, body: &[u8])

交易推送 (订单更新、成交更新等)