CloudFlow.partition

[isaacabraham]

We have the partition operator on local collections - it seems logical that we should be able to do the same for CloudFlows. Is there any reason why this wouldn't be possible? It seems to like this is a specialised form of groupBy that has a signature something like: -

'a CloudFlow -> ('a -> bool) -> ('a CloudFlow * 'a CloudFlow)

but there would need to be some way of handling the fork nature of this I guess.

[palladin]

Maybe something like this https://gist.github.com/palladin/6c5bb125160984ca67e8

[palladin]

In general the problem with partition and lazy pipelines is that you have to traverse twice.