rust-tokio Examples and Free Source Code

impl AsyncRead for tonic::Streaming...

rust async-await rust-tokio rust-rocket

How do I peek a big endian value from bytes::BytesMut?...

rust rust-tokio

Trouble Benchmarking actix_web api with Criterion...

rust async-await rust-tokio actix-web rust-criterion

How do I use a Tokio oneshot sender and receiver on different tasks with inner loops?...

rust future rust-tokio

How can I create a Tokio runtime inside another Tokio runtime without getting the error "Cannot...

rust rust-tokio

How to use Context and Wakers when implementing Future in practice...

asynchronous rust rust-tokio

How to create a polymorphic type for UnixStream and TcpStream...

rust rust-tokio

Why can't I send multiple requests in parallel using rust tonic?...

rust rust-tokio rust-async-std

Rust lazy_static and tokio::sync::mpsc::channel in tokio::select...

asynchronous rust channel rust-tokio lazy-static

MQTT connection with tokio...

rust rust-tokio

Error handling when forwarding from AsyncRead to an futures 0.3 mpsc::UnboundedSender<T>...

rust rust-tokio

Mixing select! and async calls in Rust...

rust rust-tokio rusoto crossbeam

Get the first received value from an iterator of channels in rust...

multithreading rust future channel rust-tokio

What is the idiomatic way in Rust of assigning values of different types to a variable, depending on...

rust compiler-errors compilation rust-cargo rust-tokio

Execute asyncronus function from shared library in a new thread (Rust)...

multithreading asynchronous plugins rust rust-tokio

How to translate JS Promises to Rust...

rust rust-tokio

How can I make a method stream agnostic?...

rust rust-tokio

Is it possible to preserve items in a Tokio MPSC when the last Sender is dropped, but the Reciever i...

rust rust-tokio

Does tokio::time::sleep method take task off the run queue?...

rust rust-tokio

Why do Rust lifetimes matter when I move values into a spawned Tokio task?...

rust ownership rust-tokio lifetime-scoping

How to use future::join_all with the multiplexed redis in the async tokio runtime...

redis rust async-await rust-tokio

Is there a way to make StreamExt::next non blocking (fail fast) if the stream is empty (need to wait...

rust rust-tokio

Converting a synchronous Rust IO driver to be `async`...

asynchronous rust rust-tokio mio

Spawning tasks with non-static lifetimes with tokio 0.1.x...

rust lifetime rust-tokio

Rust tokio_postgres row to object mapping fails with serde_postgres for timestamp column...

rust serde rust-tokio tokio-postgres

Why compiler says that argument doesn't implement required traits?...

rust rust-tokio hyper

How do I add tasks to a Tokio event loop that is running on another thread?...

rust future rust-tokio

Second mutable borrow error disapears after introducing a magic line...

rust rust-tokio

Receiver on "tokio::mpsc::channel" only receives messages when buffer is full...

rust async-await rust-tokio

How can I test a future that is bound to a tokio TcpStream?...

rust future rust-tokio