diff options
| author | Alex AUVOLAT <alex.auvolat@ens.fr> | 2014-03-21 13:57:16 +0100 |
|---|---|---|
| committer | Alex AUVOLAT <alex.auvolat@ens.fr> | 2014-03-21 13:57:16 +0100 |
| commit | c6313368d3719e507eba4216a4fc4ea9f30db576 (patch) | |
| tree | bdbd39f4483e1433f6470f08e081c6b6b0fa53b0 /src/primes.ml | |
| parent | 9b9bc4e787d6ecebcf15182a562fc47d27d9880d (diff) | |
| download | SystemeReseaux-Projet-c6313368d3719e507eba4216a4fc4ea9f30db576.tar.gz SystemeReseaux-Projet-c6313368d3719e507eba4216a4fc4ea9f30db576.zip | |
Retab files ; start work on networked implementation.
Diffstat (limited to 'src/primes.ml')
| -rw-r--r-- | src/primes.ml | 4 |
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 |