Stream sig

Streamsig.fsx

type Stream<'T> // abstract type

module Stream = 
  // general combinators
  val map : (Expr<'A> -> Expr<'B>) -> Stream<'A> -> Stream<'B>
  val collect : (Expr<'A> -> Stream<'B>) -> Stream<'A> -> Stream<'B>
  val filter : (Expr<'A> -> Expr<bool>) -> Stream<'A> -> Stream<'A>
  val take : Expr<int> -> Stream<'A> -> Stream<'A>
  val zipWith : (Expr<'A> -> Expr<'B> -> Expr<'C>) -> Stream<'A> -> Stream<'B> -> Stream<'C>
  // ...
  
  // producers
  val ofArray : Expr<'A []> -> Stream<'A>
  val ofList : Expr<'A list> -> Stream<'A>

  // consumers
  val length : Stream<'A> -> Expr<int>
  val toArray : Stream<'A> -> Expr<'A []>
  val toList : Stream<'A> -> Expr<'A list>
  // ...
  // helpers
  val compile : (Var<'A> -> Expr<'B>) -> ('A -> 'B)