Add pipe
Allow streams as producers
Remove _r.through in favor of pipe and streams as producers