Johan Andrén
Johan Andrén
`SinkWithContext.fromDataAndContext` seems questionable, as it implies that there is some coordination, but there is no way two sinks can be controlled/observed like that, in that case some flow branching makes...
I'm not saying that it is unheard of or unreasonable to commit an offset after consuming an element, what I'm saying is that such a stream is a `Flow`, and...
https://github.com/akka/akka/runs/8104130670?check_suite_focus=true
https://github.com/akka/akka/runs/7083636993?check_suite_focus=true#step:5:28550
I don't think this is worth the effort, the only change that matters between 1.0.3 and 1.0.4 is this one https://github.com/reactive-streams/reactive-streams-jvm/commit/b008867c90b30f99b07999c0f5546d2006f87cc6 the rest is relicensing under MiT, rule wording, and...
And that change is only to cover a corner case with what method names are in the stack trace if I understand it correctly, which is not a problem in...
`accumulate` is only one possible application of this operator, I can't think of a name that is more fitting than `statefulMap`, since it is map but with a state (which...
@patriknw I think the really tricky part was evolving the `statefulMapConcat` because of how the signature is designed. I think of where we ended up on with this as a...
@jrudolph Yes, I think we could nicely implement `statefulMapConcat` with this, once it has been out for a while and any eventual bugs has been found and squashed. Or even...
https://jenkins.akka.io:8498/job/akka-artery-cluster-tests/2705/consoleText ``` 0m[[0m[0minfo[0m] [0m[0m[[34mJVM-2[0m] [INFO] [05/02/2021 09:48:06.157] [ReplicatorPruningSpec-akka.remote.default-remote-dispatcher-17] [akka://[email protected]:49168/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports.[0m [0m[[0m[0minfo[0m] [0m[0m[[34mJVM-2[0m] [31m- must move data from removed node *** FAILED ***...