zip of partition

strymonas.ml

(* stream example that would require an unbounded buffer *)

(* read some ints from the network or something *)
(* assume this is infinite so can't buffer *)
   let long_stream = unfold read_network socket
(* filter into two streams: those above and those below 0 *)
in let bigs        = filter (fun x -> x > 0) long_stream
in let smalls      = filter (fun x -> x < 0) long_stream
(* zip the two filtered streams together *)
in let join        = zip bigs smalls
in join