Implements the Observable.windowed function that creates an observable returning a sliding window. The function is an observable version of Seq.observable. The implementation uses a simple F# agent that keeps partial windows and sends them to an observer.
6 people like thisPosted: 13 years ago by Tomas Petricek
Function that associates a time window with each element of a sequence. The resulting sequence can then be grouped by the time windows for further processing
3 people like thisPosted: 4 years ago by Faisal Waris
Creates an observable that returns windows of size 'n' (or smaller at the start) containing 'n' past values produced by observable 'source'. The order of items in the returned buffers is not guaranteed (it's a circular buffer).
3 people like thisPosted: 8 years ago by Tomas Petricek