Struct Subscription 

pub struct Subscription<M: Clone + 'static> { /* private fields */ }

A long-running message source built from one or more Recipes.

Use Subscription::none for “no subscription”. For active sources:

• Subscription::from_recipe wraps a single Recipe.
• Subscription::batch combines multiple Subscriptions into one whose recipes fire concurrently.

The runtime refreshes subscriptions after every processed message and diffs slot-by-slot by Recipe identity: recipes whose identity matches across refreshes keep their pending futures intact; new recipes spawn; missing recipes are cancelled.

Implementations

impl<M: Clone + 'static> Subscription<M>

pub fn none() -> Self

No subscription. Empty slots.

pub fn from_recipe<R>(recipe: R) -> Self

where R: Recipe<Message = M>,

Build a subscription from a single Recipe. Identity = TypeId::of::<R>() ⊕ Hash of recipe.

pub fn batch(subs: impl IntoIterator<Item = Subscription<M>>) -> Self

Combine multiple subscriptions; each underlying recipe keeps its individual identity. Nested batches flatten.

Trait Implementations

impl<M: Clone + 'static> Default for Subscription<M>

fn default() -> Self

Returns the “default value” for a type.