Trait Subscription 

pub trait Subscription<M: Send + 'static>: Send {
    // Required methods
    fn id(&self) -> SubId;
    fn run(&self, sender: Sender<M>, stop: StopSignal);
}

A subscription produces messages from an external event source.

Subscriptions run on background threads and send messages through the provided channel. The runtime manages their lifecycle.

Required Methods

fn id(&self) -> SubId

Unique identifier for deduplication.

Subscriptions with the same ID are considered identical. The runtime uses this to avoid restarting unchanged subscriptions.

fn run(&self, sender: Sender<M>, stop: StopSignal)

Start the subscription, sending messages through the channel.

This is called on a background thread. Implementations should loop and send messages until the channel is disconnected (receiver dropped) or the stop signal is received.

Implementors

impl<M: Send + 'static> Subscription<M> for Every<M>