Closed
Description
In my use case I wanted to use a timer to act as a buffer:
- i queue data
- I create or reset a timer so that after X seconds an action is performed
- if the queue reach or exceed a specific size an action is done and the timer is canceled
After looking at the code TimerSet might be my friend using the Concurrent::timer() api passing my actor as an executor instead of using the global pool but what I am missing is a way to cancel/reset (as in restart its countdown).
PS: Looking through the source code is like wandering in a big fair with interesting things everywhere ;)