summaryrefslogtreecommitdiff
path: root/src/kahn_seq.ml
diff options
context:
space:
mode:
authorAlex AUVOLAT <alex.auvolat@ens.fr>2014-05-25 01:00:44 +0200
committerAlex AUVOLAT <alex.auvolat@ens.fr>2014-05-25 01:00:44 +0200
commit4a5ca97b0970e191332fb6fb4684a397b93390f5 (patch)
treeb833cd9bf8f21514f5c0ae2ece473ac398aff251 /src/kahn_seq.ml
parent6e750a757ef6fb1f41cf4c2fe39edba834b76858 (diff)
downloadSystemeReseaux-Projet-4a5ca97b0970e191332fb6fb4684a397b93390f5.tar.gz
SystemeReseaux-Projet-4a5ca97b0970e191332fb6fb4684a397b93390f5.zip
./manager -pool-addr mypool -pool-count 16 -my-addr my_addr ./example.native
Diffstat (limited to 'src/kahn_seq.ml')
-rw-r--r--src/kahn_seq.ml4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/kahn_seq.ml b/src/kahn_seq.ml
index ce82117..177d6dd 100644
--- a/src/kahn_seq.ml
+++ b/src/kahn_seq.ml
@@ -19,6 +19,8 @@ module Seq: S = struct
let new_channel () =
let q = Queue.create () in
q, q
+
+ let output s = Format.printf "%s@?" s
let put x c =
fun cont ->
@@ -64,8 +66,6 @@ module Seq: S = struct
fun cont ->
e (Some (fun (r : 'a) -> f r cont))
- let bind_io = bind
-
let run e =
let ret = ref None in
e (Some (fun v -> ret := Some v));