A while back on the mailing list, there was a discussion on validating a stream, and splitting the stream into two sinks, depending on how the validation went:
(operator generating errors)
--> (filter) --> stream without errors --> sink
--> (filter) --> error stream --> sink
--> (filter) --> error stream --> sink
Is there an example of this implemented in (scala) code anywhere? I'm not sure how to code this up. Do I embed the error sink in the filter? The compiler hated everything I tried.
