Hi Rafał,
- sink requests data from you
> - OutletHandler.onPull is invoked on the outlet where the sink is
> connected to
> - you propagate demand outstream by calling pull on any (or all) of your
> Inlets, depending on your logic
> - eventually data becomes available upstream
> - InletHandler.onPush is invoked on the inlet you pulled previously, with
> the incoming element
>
I tried to add logging into onPull functions, but it didn't help. I see
only messages from the beggining of flow ("Message_1"), but not from my
custom shape.
OK, but the actual number of workers should not be greater than the number
> of available CPUs, because otherwise Akka will interleave their execution
> anyway. Spawning 1000s of worker flows will only waste memory. Of course I
> understand that the input of fixed collection of data is artif
>
I tried to remove balancer at all and work with the single worker. It
doesn't help.
I usually prefer to debug single problem at a time than a number of
> possibly interrelated problems at once.
>
Me too and I will try, but I am sure that it will give me nothing in this
case.
The problem is in the shape itself.
Regards,
Sergey
--
>>>>>>>>>> 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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
