Snippets tagged sliding window

  • Sliding window for Observable

    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.

    4 people like this

    Posted: 5 years ago by Tomas Petricek

  • Floating window over observables

    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 this

    Posted: 9 months ago by Tomas Petricek