Struct ActionEventSubscriber 

pub struct ActionEventSubscriber { /* private fields */ }

ActionEvent を受信して LearningDaemon に Record を送信

ActionEventPublisher から ActionEvent を受信し、 Record に変換してバッチで LearningDaemon に送信する。

対応 Event

• ActionEvent → ActionRecord

Implementations

impl ActionEventSubscriber

pub fn new(rx: Receiver<ActionEvent>, record_tx: Sender<Vec<Record>>) -> Self

新しい ActionEventSubscriber を作成

pub fn with_config( rx: Receiver<ActionEvent>, record_tx: Sender<Vec<Record>>, config: EventSubscriberConfig, ) -> Self

設定を指定して ActionEventSubscriber を作成

pub async fn run(self)

受信ループを開始

ActionEvent を受信し、Record に変換してバッチ送信する。 チャンネルが閉じられるか、送信先が閉じられたら終了。