Enum overclock::core::Subscriber

pub enum Subscriber<T: Resource> {
    OneCopy(Sender<Result<T>>),
    LinkedCopy(Option<Sender<Result<T>>>, Box<dyn Shutdown>, bool),
    DynCopy(ResourceRef, Box<dyn Route<Event<T>>>),
}

Subscriber variants

Variants

OneCopy(Sender<Result<T>>)

OneCopy subscriber will receive one copy of the resource once it’s available

LinkedCopy(Option<Sender<Result<T>>>, Box<dyn Shutdown>, bool)

LinkedOneCopy subscriber will receive one copy of the resource once it’s available, subscriber will get shutdown if the resource is replaced or dropped.

DynCopy(ResourceRef, Box<dyn Route<Event<T>>>)

Subscriber will receive dynamic copies, pushed by the publisher, and Event::Dropped(..) will be pushed if the resource got dropped by the publisher. Bool flag is used to indicate wheith

Implementations

impl<T: Resource> Subscriber<T>

pub fn one_copy(one_shot: Sender<Result<T>>) -> Self

Create subscriber for one copy

pub fn linked_copy(
    one_shot: Sender<Result<T>>,
    shutdown_handle: Box<dyn Shutdown>,
    hard_link: bool
) -> Self

Create linked subscriber for one copy hard_link: true links the subscriber if the publisher published new copy

pub fn dyn_copy(
    res_ref: ResourceRef,
    boxed_route: Box<dyn Route<Event<T>>>
) -> Self

Create subscriber for dynamic copies.