I've simplified the problem. The internals of createObject for handlers
are now just:
setHandler(out, new OutHandler{
override def onPull():Unit = {
Thread.sleep(1000)
push(out,List(1,2,3))
}
})
setHandler(data, new InHandler{
override def onPush():Unit = {
println("Data: "+grab(data))
}
})
setHandler(tick, new InHandler{
override def onPush():Unit = {
grab(tick) // clear tick's payload...don't care about it otherwise
println("Tick!")
}
})
When I run this I only see the List(1,2,3) output, meaning my output
handler is being called but no InHandler.onPush methods are being called.
Anyone know why?
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
