Struct GrpcPushBroadcaster 

pub struct GrpcPushBroadcaster { /* private fields */ }

gRPC 推送广播器

实现 ExternalPushSink trait，接收 PushDispatcher 的推送事件， 通过 broadcast channel 分发给所有 SubscribePush 流式连接。

Implementations

impl GrpcPushBroadcaster

pub fn new(capacity: usize) -> Self

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

创建接收端

Trait Implementations

impl Clone for GrpcPushBroadcaster

fn clone(&self) -> GrpcPushBroadcaster

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ExternalPushSink for GrpcPushBroadcaster

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

v1.4.106 codex 1131 F4 [P1]: rehab_type 透传到 gRPC PushEvent. gRPC 当前 broadcast 模型 (所有 qot:read subscriber 收到所有 quote event), per-conn (sec_key, sub_type, rehab_type) 三元 filter 是 raw TCP 专属. rehab_type 通过 PushEvent 让客户端可见.

fn on_trade_push( &self, acc_id: u64, proto_id: u32, body: &[u8], trd_market: Option<&str>, )

v1.4.105 D3 (Phase 4) T-B3: trade push trd_market 由 PushDispatcher 一 次 decode 后透传, 不再各 sink 独立 decode body. 空 / unknown → 空 字符串 (PushEvent proto3 默认值, 老 client 解析兼容).

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

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