The bug (yes, it is one) and the fix are here
https://github.com/akka/akka/pull/17188. Thanks for the very good report,
Johannes!
Regards,
Roland
13 apr 2015 kl. 19:20 skrev Viktor Klang viktor.kl...@gmail.com:
Is if(input eq p.priority) also true?
On Mon, Apr 13, 2015 at 7:11 PM,
Hi,
While implementing a FlexiMerge we stumbled on the following issue:
override def initialState =
State[T](ReadPreferred(p.priority, p.second)) {
(ctx, input, element) =
if(input == p.priority).. // always true
ctx.emit(element)
Is if(input eq p.priority) also true?
On Mon, Apr 13, 2015 at 7:11 PM, Johannes Plapp johannes.pl...@gmail.com
wrote:
Hi,
While implementing a FlexiMerge we stumbled on the following issue:
override def initialState =
State[T](ReadPreferred(p.priority, p.second)) {
