Trait riker::system::Timer

pub trait Timer {
    type Msg: Message;

    fn schedule<T>(
        &self,
        initial_delay: Duration,
        interval: Duration,
        receiver: ActorRef<Self::Msg>,
        sender: Option<ActorRef<Self::Msg>>,
        msg: T
    ) -> Uuid
    where
        T: Into<ActorMsg<Self::Msg>>;
    fn schedule_once<T>(
        &self,
        delay: Duration,
        receiver: ActorRef<Self::Msg>,
        sender: Option<ActorRef<Self::Msg>>,
        msg: T
    ) -> Uuid
    where
        T: Into<ActorMsg<Self::Msg>>;
    fn schedule_at_time<T>(
        &self,
        time: DateTime<Utc>,
        receiver: ActorRef<Self::Msg>,
        sender: Option<ActorRef<Self::Msg>>,
        msg: T
    ) -> Uuid
    where
        T: Into<ActorMsg<Self::Msg>>;
    fn cancel_schedule(&self, id: Uuid);
}

Required Associated Types

type Msg: Message

Required Methods

fn schedule<T>(
    &self,
    initial_delay: Duration,
    interval: Duration,
    receiver: ActorRef<Self::Msg>,
    sender: Option<ActorRef<Self::Msg>>,
    msg: T
) -> Uuidwhere
    T: Into<ActorMsg<Self::Msg>>,

fn schedule_once<T>(
    &self,
    delay: Duration,
    receiver: ActorRef<Self::Msg>,
    sender: Option<ActorRef<Self::Msg>>,
    msg: T
) -> Uuidwhere
    T: Into<ActorMsg<Self::Msg>>,

fn schedule_at_time<T>(
    &self,
    time: DateTime<Utc>,
    receiver: ActorRef<Self::Msg>,
    sender: Option<ActorRef<Self::Msg>>,
    msg: T
) -> Uuidwhere
    T: Into<ActorMsg<Self::Msg>>,

fn cancel_schedule(&self, id: Uuid)

Implementors

impl<Msg> Timer for Context<Msg>where
    Msg: Message,

type Msg = Msg

impl<Msg> Timer for ActorSystem<Msg>where
    Msg: Message,

type Msg = Msg