A Rust library providing a generic cancellable utility.
The goal of this library is to provide a unified way of defining background
services that are managed by the tokio runtime.
For working examples see examples/ folder.
```rust use std::{error::Error, net::SocketAddr};
use cancellable::{async_trait, Cancellable, CancellationResult}; use tokio::net::{TcpListener, TcpStream};
struct Listener { tcp_listener: TcpListener, }
impl Listener {
async fn new() -> Result
Ok(Self { tcp_listener })
}
}
impl Cancellable for Listener { type Result = (TcpStream, SocketAddr); type Handle = (); type Error = std::io::Error;
async fn new_handle(&mut self) -> Self::Handle {}
async fn run(&mut self) -> Result<CancellationResult<Self::Result>, Self::Error> {
let (addr, stream) = self.tcp_listener.accept().await?;
Ok(CancellationResult::item((addr, stream)))
}
} ```
See LICENSE.txt file.