Skip to main content

Subscription

Struct Subscription 

Source
pub struct Subscription<Msg> { /* private fields */ }
Expand description

A set of continuous message sources, possibly empty.

Implementations§

Source§

impl<Msg: Send + 'static> Subscription<Msg>

Source

pub fn none() -> Self

No subscription at all.

Source

pub fn batch(subscriptions: impl IntoIterator<Item = Subscription<Msg>>) -> Self

Groups several subscriptions together.

Source

pub fn every( interval: Duration, make: impl Fn(Instant) -> Msg + Send + 'static, ) -> Self

Emits a message every interval; the tick’s Instant is passed along.

Source

pub fn every_keyed( key: u64, interval: Duration, make: impl Fn(Instant) -> Msg + Send + 'static, ) -> Self

Subscription::every under an identity of the caller’s: two timers of the same period are two subscriptions when their keys differ, and one that keeps its key from one cycle to the next keeps running.

Source

pub fn is_empty(&self) -> bool

true when there is no subscription.

Source

pub fn ids(&self) -> Vec<u64>

The subscriptions’ ids, for inspection and testing.

Auto Trait Implementations§

§

impl<Msg> !RefUnwindSafe for Subscription<Msg>

§

impl<Msg> !Sync for Subscription<Msg>

§

impl<Msg> !UnwindSafe for Subscription<Msg>

§

impl<Msg> Freeze for Subscription<Msg>
where Vec<Entry<Msg>>: Freeze,

§

impl<Msg> Send for Subscription<Msg>
where Vec<Entry<Msg>>: Send,

§

impl<Msg> Unpin for Subscription<Msg>
where Vec<Entry<Msg>>: Unpin,

§

impl<Msg> UnsafeUnpin for Subscription<Msg>
where Vec<Entry<Msg>>: UnsafeUnpin,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> Downcast for T
where T: Any,

Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.
Source§

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.
Source§

fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.
Source§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.
Source§

impl<T> Downcast<T> for T

Source§

fn downcast(&self) -> &T

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<Msg> IntoMsg<Msg> for Msg

Source§

fn defer(work: impl Fn() -> Msg + 'static) -> Msg

The message that stands for work’s result.
Source§

impl<T> MaybeSend for T
where T: Send,

Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> Upcast<T> for T

Source§

fn upcast(&self) -> Option<&T>

Source§

impl<T> WasmNotSend for T
where T: Send,

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more