Re: [akka-user] ReadPrefered in FlexiMerge (akka-streams)

The bug (yes, it is one) and the fix are here . Thanks for the very good report, Johannes! Regards, Roland > 13 apr 2015 kl. 19:20 skrev Viktor Klang : > > Is if(input eq p.priority) also true? > > On Mon, Apr 13, 2015 at 7:11 PM, Johannes Plapp

Re: [akka-user] ReadPrefered in FlexiMerge (akka-streams)

Is if(input eq p.priority) also true? On Mon, Apr 13, 2015 at 7:11 PM, Johannes Plapp wrote: > Hi, > > While implementing a FlexiMerge we stumbled on the following issue: > > override def initialState = > State[T](ReadPreferred(p.priority, p.second)) { > (ctx, input, elemen

[akka-user] ReadPrefered in FlexiMerge (akka-streams)

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) S