Re: [akka-user] Re: Unordered merge of 2..n streams created by groupBy

2015-01-09 Thread Patrik Nordwall
Hi Tim, Thanks for your interest in contributing. That is of course welcome. Please start by creating an issue, if there is no one already. I don't know if the functionality or design needs any discussion, but that is something we can do in the issue. Base the pull request on branch release-2.3-de

[akka-user] Re: Unordered merge of 2..n streams created by groupBy

2015-01-08 Thread Tim Harper
Akka maintainers, how does this solution look (see mentioned gist in quoted text)? I'll probably need some degree of guidance, but this solution is working well for my needs; I'm happy to produce a pull-request for Akka streams to implement FlattenStrategy.mergeUnordered. On Wednesday, January

[akka-user] Re: Unordered merge of 2..n streams created by groupBy

2015-01-07 Thread Tim Harper
Gist is here: https://gist.github.com/timcharper/a6642275bfaebbd2194d On Tuesday, January 6, 2015 11:39:22 AM UTC-7, Tim Harper wrote: > > I am modeling a data processing pipeline where there are several decision > points, where the system may refer to a human being to make a decision. > Since e

[akka-user] Re: Unordered merge of 2..n streams created by groupBy

2015-01-06 Thread Tim Harper
Further studying convinces me that this is not yet implemented. I'm going to pursue the ActorPublisher / ActorSubscriber route; thank you for this documentation page , Akka-Stream folks! I'll post