tokio-sync-read-stream
Transforms a std::io::Read into a fallable futures::stream::Stream that yields Result<Vec<u8>, std::io::Error>
.
Under the hood, it reads from the file in chunks of up to buffer_size
on a Tokio blocking thread using spawn_blocking. A Handle to the Tokio runtime must be provided.
Usage
Add the library as a dependency:
Sample Rust code:
use File;
use SyncReadStream;
async