2 stable releases

Uses old Rust 2015

1.0.1 Dec 4, 2018
1.0.0 Feb 8, 2018

#1429 in Asynchronous

33 downloads per month


109 lines


Crates.io Documentation Build Status

This crate provides ThrottledReader, a proxy-type for io::Read that limits how many times the underlying reader can be read from. If the read budget is exceeded, io::ErrorKind::WouldBlock is returned instead. This type can be useful to enforce fairness when reading from many (potentially asynchronous) input streams with highly varying load. If one stream always has data available, a worker may continue consuming its input forever, neglecting the other stream.


let mut buf = [0];
let mut stream = ThrottledReader::new(io::empty());

// initially no limit
assert!(stream.read(&mut buf).is_ok());
assert!(stream.read(&mut buf).is_ok());

// set a limit
assert!(stream.read(&mut buf).is_ok()); // first is allowed through
assert!(stream.read(&mut buf).is_ok()); // second is also allowed through
// but now the limit is reached, and the underlying stream is no longer accessible
    stream.read(&mut buf).unwrap_err().kind(),

// we can then unthrottle it again after checking other streams
assert!(stream.read(&mut buf).is_ok());
assert!(stream.read(&mut buf).is_ok());

No runtime deps