rabbitmq-stream-client 0.6.0

A Rust client for RabbitMQ Stream
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
pub struct TaskHandle {
    task: tokio::task::JoinHandle<()>,
}

impl From<tokio::task::JoinHandle<()>> for TaskHandle {
    fn from(task: tokio::task::JoinHandle<()>) -> Self {
        TaskHandle { task }
    }
}

impl Drop for TaskHandle {
    fn drop(&mut self) {
        self.task.abort();
    }
}