4 releases (breaking)
0.4.0 | Dec 20, 2019 |
---|---|
0.3.0 | Dec 19, 2019 |
0.2.0 | Apr 17, 2019 |
0.1.0 | Mar 16, 2019 |
#1388 in Asynchronous
Used in fie-ffi
17KB
298 lines
tokio-global
Simple way to create global tokio runtime, available from any place in code
Usage
Start runtime and use AutoRuntime
trait to spawn your futures:
use tokio_global::{Runtime, AutoRuntime};
use tokio::io::{AsyncWriteExt, AsyncReadExt};
async fn server() {
let mut listener = tokio::net::TcpListener::bind("127.0.0.1:8080").await.expect("To bind");
let (mut socket, _) = listener.accept().await.expect("To accept connection");
async move {
let mut buf = [0; 1024];
loop {
match socket.read(&mut buf).await {
// socket closed
Ok(0) => return,
Ok(_) => continue,
Err(_) => panic!("Error :("),
};
}
}.spawn().await.expect("Finish listening");
}
async fn client() {
let mut stream = tokio::net::TcpStream::connect("127.0.0.1:8080").await.expect("Connect");
// Write some data.
stream.write_all(b"hello world!").await.expect("Write");
//Stop runtime
Runtime::stop();
}
let _guard = Runtime::default();
let runner = std::thread::spawn(|| {
Runtime::run();
});
server().spawn();
client().spawn();
Dependencies
~3.5MB
~50K SLoC