A lambda-based streaming library. Read the introduction here.
For native ocaml:
opam install lambda-streams
For bucklescript:
yarn add lambda-streams
See documentation
There are several kinds of streams. The simplest is a Finite.Sync stream:
# #require "lambda_streams";;
# open Lambda_streams;;
# let foo = Finite.Sync.from_list [1; 2; 3];;
val foo : int Finite.Sync.input = <fun>
# let bar = foo |> Finite.Sync.map (( * ) 2) |> Finite.Sync.to_list;;
val bar : int list = [2; 4; 6]See LICENSE