Tokio makes it very easy. We just wrap a

Stream

or

Future

with

tokio::timeout::Timeout

. I only can't figure out where to wrap it I got a failing unit test at least 🙂