Struct Subscriber 

pub struct Subscriber { /* private fields */ }

Subscriber - 负责订阅任务事件和通知 Subscriber - responsible for subscribing to task events and notifications

对应 Go asynq 的 subscriber 组件 Corresponds to Go asynq’s subscriber component

Subscriber 允许应用程序订阅任务生命周期事件，用于监控、日志记录或触发其他操作。 Subscriber allows applications to subscribe to task components events for monitoring, logging, or triggering other actions.

Implementations

impl Subscriber

pub fn new(broker: Arc<dyn Broker>, config: SubscriberConfig) -> Self

创建新的 Subscriber Create a new Subscriber

pub fn take_receiver(&mut self) -> Option<Receiver<SubscriptionEvent>>

获取事件接收器 Get event receiver

调用此方法后，接收器的所有权将转移，后续调用将返回 None After calling this method, ownership of the receiver is transferred, subsequent calls will return None

pub fn start(self: Arc<Self>) -> JoinHandle<()>

启动 Subscriber Start the Subscriber

对应 Go 的 subscriber.start() Corresponds to Go’s subscriber.start()

pub async fn publish(&self, event: SubscriptionEvent) -> Result<()>

发布事件 Publish event

此方法允许其他组件发布事件到订阅者 This method allows other components to publish events to subscribers

pub fn shutdown(&self)

停止 Subscriber Stop the Subscriber

对应 Go 的 subscriber.shutdown() Corresponds to Go’s subscriber.shutdown()

pub fn is_done(&self) -> bool

检查是否已完成 Check if done

Trait Implementations

impl ComponentLifecycle for Subscriber

fn start(self: Arc<Self>) -> JoinHandle<()>

启动组件 Start the component

fn shutdown(&self)

关闭组件 Shutdown the component

fn is_done(&self) -> bool

检查组件是否已完成 Check if the component is done