138
(* 1-position communication channels: *)
141
(* The channel may be empty or it may contain a message for someone *)
142
type 'a t = ('a option) Cortex.t
145
?equality:('a -> 'a -> bool) ->
146
?on_proposal:('a option -> 'a option -> 'a option) ->
147
?on_commit:('a option -> 'a option -> unit) ->
151
val receive : 'a t -> 'a
152
val send : 'a t -> 'a -> bool (* success/failure of sending *)
157
type t = int Cortex.t
158
val make : ?init:int -> ?limit:int -> ?delay:float -> unit -> t