pub fn map<I, O, F>(f: F) -> Pipe<I, O>where F: Fn(I) -> O + Send + Sync + Clone + 'static, I: Send + 'static, O: Send + 'static,
Create a pipe that applies the given function to each element