Category "rust-tokio"

What is a "projection" and how does it relate to a StreamReader?

I'm receiving RecordBatches serialized as bytes and I'm trying to de-serialize into RecordBatches. Using StreamReader::try_new() and passing in the byte data an

Poll raw file descriptor for data

I would like to poll a raw file descriptor for data and process it as it gets written to. This needs to be done on a separate thread so that my main thread is

How to reuse Tokio runtime in Rust FFI library

I want to write a FFI wrapper for sn_api library, which contains async functions. It will be used in single-threaded non-async code written in Red. I found, tha

Programmatically create and listen for multiple signals and a ticking interval with tokio

I'm trying to programmatically listen to multiple signals and a ticking interval. To clear things up, here is the code I have currently: use std::time::Duration