Create a new stream that passes all values through a function and forwards them to a target stream. - View it on GitHub