I like the throttle version more ;)
On Sun, Mar 20, 2016 at 4:24 PM, Roland Kuhn wrote:
> Yes, and for the immediate case you can use Future.successful.
>
> Regards, Roland
>
> Sent from my iPhone
>
> On 20 Mar 2016, at 15:41, john.vie...@gmail.com wrote:
>
> Something very
Yes, and for the immediate case you can use Future.successful.
Regards, Roland
Sent from my iPhone
> On 20 Mar 2016, at 15:41, john.vie...@gmail.com wrote:
>
> Something very simple which come to my mind is to mapAsync to the ask
> pattern and then do a "schedule of 10 secs" if the element
Hi John,
I think it is easier to use the built-in throttle:
- set the capacity to zero
- set the token rate to 1/second
- use an explicit cost function, setting the cost of non-empty sequences
to zero, and the cost of empty-ones to ten.
-Endre
On Sun, Mar 20, 2016 at 6:06 PM,
I came up with this code:
http://pastebin.com/LNTCvebe
But beware until now I have only be using akka with java. It is my first
try on using scala!
As a side note : I could not figure out how to match an non-empty list in
receive?
Many Greetings
John
Am Sonntag, 20. März 2016 14:31:51
Something very simple which come to my mind is to mapAsync to the ask
pattern and then do a "schedule of 10 secs" if the element is an empty list.
Am Sonntag, 20. März 2016 14:31:51 UTC+1 schrieb john@gmail.com:
>
> val input = Source(List(List(1, 2, 3), List(1, 2, 3), List(),
>