Provide functional style interface to pipe sources, transform them and more