rust_task.rs

trait ReceiverTask {
    type Message;
    async fn invoke(&mut self, message: Self::Message);
}

enum ReceiverTaskMessage<M> {
    Shutdown,
    Timeout,
    Message(M),
}

struct Runner<T: ReceiverTask> {
    task: JoinHandle<()>,
    sender: Sender<ReceiverTaskMessage<T::Message>>,
    pd: PhantomData<&'static T>,
}

impl<T: ReceiverTask> Runner<T> {
    pub fn shutdown(&self) {
        self.sender.send(ReceiverTaskMessage::Shutdown);
    }
    pub fn timeout(&self) {
        self.sender.send(ReceiverTaskMessage::Timeout);
    }
    pub fn send(&self, message: T::Message) {
        self.sender.send(ReceiverTaskMessage::Message(message));
    }
}