Hey guys. I have been trying to setup a stream using throttle, but I am
seeing some weird behavior. In the following stream I am seeing a peak of
20k events per second in my publish stat.
Source.fromGraph(eventBusSource)
.via(filter)
.expand(Iterator.continually(_))
.via(StreamUtils.parallelize(10, modify))
// .throttle(eventsPerSecond, 1.second, 1, ThrottleMode.Shaping)
.via(StreamUtils.parallelize(20, publishFlow))
.takeWithin(duration)
.viaMat(KillSwitches.single)(Keep.right)
.toMat(Sink.fold(0)((acc, _) => acc + 1))(Keep.both)
However, when I uncomment the throttle stage and set events per second to
5k, the speed at which I publish drops to a few hundred per second. For
some reason, the throttle stage is dramatically slowing down my graph.
Am I just not understanding some fundamental concept about throttle?
--
>>>>>>>>>> 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.
