diff options
| author | Alex AUVOLAT <alex.auvolat@ens.fr> | 2014-03-20 16:39:16 +0100 |
|---|---|---|
| committer | Alex AUVOLAT <alex.auvolat@ens.fr> | 2014-03-20 16:39:16 +0100 |
| commit | 9b9bc4e787d6ecebcf15182a562fc47d27d9880d (patch) | |
| tree | b629d6a0c3c6f0d80dbde8e0bc6252d99f1d834e /src/primes.ml | |
| parent | 084745ffe51234e366ed6627d9f697c47d87bb4a (diff) | |
| download | SystemeReseaux-Projet-9b9bc4e787d6ecebcf15182a562fc47d27d9880d.tar.gz SystemeReseaux-Projet-9b9bc4e787d6ecebcf15182a562fc47d27d9880d.zip | |
Added implementation with pipes.
Diffstat (limited to 'src/primes.ml')
| -rw-r--r-- | src/primes.ml | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/primes.ml b/src/primes.ml index 0911f31..e0eeed7 100644 --- a/src/primes.ml +++ b/src/primes.ml @@ -32,11 +32,12 @@ module Primes (K : Kahn.S) = struct let main : unit process = (delay new_channel ()) >>= - (fun (q_in, q_out) -> doco [ integers 5000 q_out ; primes q_in ]) + (fun (q_in, q_out) -> doco [ integers 2000 q_out ; primes q_in ]) end -module P = Primes(Kahn.Seq) +module Eng = Kahn.Pipe +module P = Primes(Eng) let () = P.K.run P.main |