pub fn idle_timeout<T: Send + 'static>(
src: Source<T>,
idle: Duration,
) -> Source<T>Expand description
idle_timeout(d) — complete the stream early if no element
arrives for d. We surface “completed early” so a downstream
recover_with / Sink::collect_with_status can disambiguate.