Simão,
you might be trying to push too many values downstream, I think you should
replace your Math.max by Math.min for a start. Are you sure your
subscription isn’t canceled rapidly because of this force-feeding? Also,
have you tried logging your Request branch in receive and display
totalDemand
Here is the code for my actor:
https://gist.github.com/simao/3003ee256751cfb7b2f7
If i put a log message on `deliverBuf` then I see that this method gets
called for each event, but totalDemand is always 0.
Thank you for your help.
Simao
On Wednesday, March 9, 2016 at 10:41:13 PM UTC+1,
Your actor is supposed to receive ActorPublisherMessage.Request message
after the stream is materialized. At this point totalDemand should be > 0
and you are allowed to call onNext
Can you show the code of your publisher actor?
Cheers,
Rafał
W dniu środa, 9 marca 2016 13:48:27 UTC+1
