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, 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])

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