sig
  val read_stream :
    (string -> 'a array) -> Pervasives.in_channel -> 'Stream.t
  val write_stream :
    ?chunk_len:int ->
    ('a array -> string) -> Pervasives.out_channel -> 'Stream.t -> unit
  val test : int list -> bool
end