Function rescue 

pub fn rescue<S: Clone + 'static>(
    recover: impl Fn(&str) -> S + 'static,
) -> Operator<S>

rescue: absorb upstream ERROR and replace it with recover(error_message).