Re: [akka-user] Re: Can this be done with the build in stages?

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

Re: [akka-user] Re: Can this be done with the build in stages?

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

Re: [akka-user] Re: Can this be done with the build in stages?

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,

[akka-user] Re: Can this be done with the build in stages?

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

[akka-user] Re: Can this be done with the build in stages?

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(), >