summaryrefslogtreecommitdiff
path: root/src/primes.ml
diff options
context:
space:
mode:
Diffstat (limited to 'src/primes.ml')
-rw-r--r--src/primes.ml4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/primes.ml b/src/primes.ml
index e0eeed7..924f7d3 100644
--- a/src/primes.ml
+++ b/src/primes.ml
@@ -25,7 +25,7 @@ module Primes (K : Kahn.S) = struct
let rec primes (qi : int in_port) : unit process =
(get qi) >>= (fun v ->
if v <> -1 then begin
- Format.printf "%d@." v;
+ io_write ((string_of_int v)^"\n");
(delay new_channel ()) >>=
(fun (qi2, qo2) -> doco [ filter v qi qo2 ; primes qi2 ])
end else return ())
@@ -36,7 +36,7 @@ module Primes (K : Kahn.S) = struct
end
-module Eng = Kahn.Pipe
+module Eng = Kahn.Seq
module P = Primes(Eng)
let () = P.K.run P.main