window

fun window(size: Int): Event<List<A>>(source)

Takes and event, and constructs a moving window of size when events occur.

This is useful for things like calculating moving averages for the values of an Event.