Runlet.Cmd.Flow (runlet v1.2.7)

View Source

Flow control events

Summary

Functions

exec(stream, flow_count, flow_seconds)

Drop events that exceed a rate in count per seconds.

Functions

exec(stream, flow_count, flow_seconds)

@spec exec(Enumerable.t(), pos_integer(), pos_integer()) :: Enumerable.t()

Drop events that exceed a rate in count per seconds.