It still has a bug I cannot find, on complicated streams it pushes elements
A :
ctx.emit(element)
but they don't arrive into the Sink that follows and the stream blocks
indefinitely ... Any idea ?
--
Read the docs: http://akka.io/docs/
Check the FAQ:
FlexiMerge seems to be a valid solution to this problem :
class BypassMerge[A, B] extends FlexiMerge[A, FanInShape2[A, B, A]](new
FanInShape2(BypassMerge), OperationAttributes.name(BypassMerge)) {
def createMergeLogic(p: PortT): MergeLogic[A] = new MergeLogic[A] {
val readA: State[A] =
It required a little bit of Round Robing : -)
class RoundRobinBypassingMerge[A, B] extends FlexiMerge[A, FanInShape2[A, B,
A]](new FanInShape2(RRBMerge), OperationAttributes.name(RRBMerge)) {
def createMergeLogic(p: PortT): MergeLogic[A] = new MergeLogic[A] {
val read1: State[A] =
