From 8afa5bb9d6e5a0f59d13bcdc9bc2e153c336445d Mon Sep 17 00:00:00 2001 From: Alex Auvolat Date: Fri, 13 Mar 2015 11:16:30 +0100 Subject: Commit uncommited stuff. --- src/primes.ml | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) (limited to 'src/primes.ml') diff --git a/src/primes.ml b/src/primes.ml index 6975b9e..c5a1831 100644 --- a/src/primes.ml +++ b/src/primes.ml @@ -28,20 +28,21 @@ module Primes (K : Kahn.S) = struct (get qi) >>= (fun v -> if v <> -1 then begin - K.output @@ Format.sprintf "%d@." v; - (delay new_channel ()) >>= - (fun (qi2, qo2) -> doco [ filter v qi qo2 ; primes qi2 ]) + K.output (string_of_int v ^ "\n"); + let qi2, qo2 = new_channel () in + doco [ filter v qi qo2 ; primes qi2 ] end else return ()) let main : int process = - (delay new_channel ()) >>= - (fun (q_in, q_out) -> doco [ integers 2000 q_out ; primes q_in ]) + (return ()) >>= + (fun () -> let q_in, q_out = new_channel () in + doco [ integers 10000 q_out ; primes q_in ]) >>= (fun () -> return 42) end -module Eng = Kahn_seq.Seq +module Eng = Kahn_pipe.Pipe module P = Primes(Eng) let () = -- cgit v1.2.3