pub fn fixed_delay(delay: time::Duration, stream: S) -> Self {
        Self {
            delay,
            failed: false,
            sleep: time::sleep(time::Duration::ZERO),
            sleeping: false,
            stream,
        }
    }
/// Creates an error handling stream that uses a fixed delay on consecutive errors
Creates an error handling stream that uses a fixed delay on consecutive errors
Creates an error handling stream that uses a fixed delay on consecutive errors
pub fn fixed_delay(delay: time::Duration, stream: S) -> Self {
        Self {
            delay,
            failed: false,
            sleep: time::sleep(time::Duration::ZERO),
            sleeping: false,
            stream,
        }
    }
pub fn fixed_delay ( delay : time :: Duration , stream : S ) -> Self { Self { delay , failed : false , sleep : time :: sleep ( time :: Duration :: ZERO ) , sleeping : false , stream , } }
Creates an error handling stream that uses a fixed delay on consecutive errors
Creates an error handling stream that uses a fixed delay on consecutive errors
delay
time::Duration
stream
S
delay
time::Duration
stream
S