Struct ActionEventPublisher 

pub struct ActionEventPublisher { /* private fields */ }

行動イベント配信システム

broadcast channel で ActionEvent を配信。 Subscriber パターンでオンライン統計・永続化を分離。

Implementations

impl ActionEventPublisher

pub fn new(capacity: usize) -> (Self, Receiver<ActionEvent>)

新規作成

Arguments

• capacity - broadcast channel のバッファサイズ

Returns

• ActionEventPublisher - 配信システム
• broadcast::Receiver<ActionEvent> - 最初の Receiver

pub fn publish(&self, event: ActionEvent)

イベントを配信

全ての Subscriber に配信される。 Subscriber がいない場合は何もしない（エラーにならない）。

pub fn publish_batch(&self, events: impl IntoIterator<Item = ActionEvent>)

複数イベントを一括配信

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

追加の Receiver を取得

pub fn sender(&self) -> Sender<ActionEvent>

Sender を取得

pub fn subscriber_count(&self) -> usize

現在の Subscriber 数

pub fn record(&self, event: ActionEvent)

record() の別名（後方互換）

pub fn record_batch(&self, events: impl IntoIterator<Item = ActionEvent>)

record_batch() の別名（後方互換）