Function try_extractor 

pub fn try_extractor<S, T, U, E, F>(
    stream: S,
    decode: F,
) -> impl Stream<Item = Result<U, E>>
where
    S: Stream<Item = Result<Vec<T>, E>>,
    F: Fn(T) -> Result<U, E> + Clone,