A stream processing library for F#