From 9b9bc4e787d6ecebcf15182a562fc47d27d9880d Mon Sep 17 00:00:00 2001
From: Alex AUVOLAT <alex.auvolat@ens.fr>
Date: Thu, 20 Mar 2014 16:39:16 +0100
Subject: Added implementation with pipes.

---
 src/primes.ml | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'src/primes.ml')

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
 
-- 
cgit v1.2.3