tokio-global

Crates.iotokio-global
lib.rstokio-global
version0.4.0
sourcesrc
created_at2019-03-16 08:21:11.048062
updated_at2019-12-20 14:43:15.552206
descriptionGlobal tokio runtime
homepage
repositoryhttps://gitlab.com/Douman/tokio-global
max_upload_size
id121324
size18,997
Douman (DoumanAsh)

documentation

README

tokio-global

Build Crates.io Documentation

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();
Commit count: 14

cargo fmt