You'll need to pull the inputs as well. But another thing: one innocent kitten dies for every millisecond you sleep in those handlers!
Sent from my iPhone > On 02 Dec 2015, at 00:44, tigerfoot <[email protected]> wrote: > > 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. -- >>>>>>>>>> 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.
