using RichPipe for a stream to split multiple pipe