astarte-platform/astarte_flow

Fix random_source delay implementation

rbino opened this issue · 0 comments

rbino commented

The current implementation of the delay between events instead of waiting for x milliseconds before sending a single event, waits for x * N milliseconds before sending N events, where N is the demand from the consumers.

This causes the random_source block to "freeze" very quickly since the default demand is around 1000. The implementation should be fixed to make it work as intended.