Stream Processing with OCaml