package lambda_streams

  1. Overview
  2. Docs

Represents the finite version of a Lambda_streams.Sync stream.

type 'a input = 'a Signal.t Sync.input
type 'a output = 'a Sync.output
val make_output : ('a -> unit) -> 'a output
val send : 'a -> 'a output -> unit
val pure : 'a -> 'a input
val empty : unit -> 'a input
val from_list : 'a list -> 'a input
val from_array : 'a array -> 'a input
val pipe : 'a output -> 'a input -> unit

Pipes an input stream into an output stream.

val map : ('a -> 'b) -> 'a input -> 'b input
val filter : ('a -> bool) -> 'a input -> 'a input
val take : int -> 'a input -> 'a input
val take' : int -> 'a Sync.input -> 'a input
val skip : int -> 'a input -> 'a input
val until : ('a -> bool) -> 'a input -> 'a input
val fold_left : ('a -> 'b -> 'a) -> 'a -> 'b input -> 'a
val concat : 'a input list -> 'a input
val flatten : 'a input input -> 'a input
val to_rev_list : 'a input -> 'a list
val to_list : 'a input -> 'a list
val to_array : 'a input -> 'a array