sig
type group = Unixqueue_util.group
exception Abort of (Unixqueue.group * exn)
type wait_id = Unixqueue_util.wait_id
type operation =
Unixqueue_util.operation =
Wait_in of Unix.file_descr
| Wait_out of Unix.file_descr
| Wait_oob of Unix.file_descr
| Wait of Unixqueue.wait_id
type event =
Unixqueue_util.event =
Input_arrived of (Unixqueue.group * Unix.file_descr)
| Output_readiness of (Unixqueue.group * Unix.file_descr)
| Out_of_band of (Unixqueue.group * Unix.file_descr)
| Timeout of (Unixqueue.group * Unixqueue.operation)
| Signal
| Extra of exn
| Immediate of (Unixqueue.group * (unit -> unit))
class type event_system =
object
method add_abort_action :
Unixqueue.group -> (Unixqueue.group -> exn -> unit) -> unit
method add_close_action :
Unixqueue.group ->
Unix.file_descr * (Unix.file_descr -> unit) -> unit
method add_event : Unixqueue.event -> unit
method add_handler :
Unixqueue.group ->
(Unixqueue.event_system ->
Unixqueue.event Equeue.t -> Unixqueue.event -> unit) ->
unit
method add_resource :
Unixqueue.group -> Unixqueue.operation * float -> unit
method add_weak_resource :
Unixqueue.group -> Unixqueue.operation * float -> unit
method clear : Unixqueue.group -> unit
method exists_resource : Unixqueue.operation -> bool
method is_running : bool
method new_group : unit -> Unixqueue.group
method new_wait_id : unit -> Unixqueue.wait_id
method remove_resource : Unixqueue.group -> Unixqueue.operation -> unit
method run : unit -> unit
method when_blocking : (unit -> unit) -> unit
end
class standard_event_system : unit -> event_system
val standard_event_system : unit -> Unixqueue.event_system
class unix_event_system : unit -> event_system
val create_unix_event_system : unit -> Unixqueue.event_system
class performance_event_system : unit -> event_system
val performance_event_system : unit -> Unixqueue.event_system
val new_group : Unixqueue.event_system -> Unixqueue.group
val new_wait_id : Unixqueue.event_system -> Unixqueue.wait_id
val exists_resource : Unixqueue.event_system -> Unixqueue.operation -> bool
val add_resource :
Unixqueue.event_system ->
Unixqueue.group -> Unixqueue.operation * float -> unit
val add_weak_resource :
Unixqueue.event_system ->
Unixqueue.group -> Unixqueue.operation * float -> unit
val add_close_action :
Unixqueue.event_system ->
Unixqueue.group -> Unix.file_descr * (Unix.file_descr -> unit) -> unit
val add_abort_action :
Unixqueue.event_system ->
Unixqueue.group -> (Unixqueue.group -> exn -> unit) -> unit
val remove_resource :
Unixqueue.event_system -> Unixqueue.group -> Unixqueue.operation -> unit
val add_handler :
Unixqueue.event_system ->
Unixqueue.group ->
(Unixqueue.event_system ->
Unixqueue.event Equeue.t -> Unixqueue.event -> unit) ->
unit
val add_event : Unixqueue.event_system -> Unixqueue.event -> unit
val clear : Unixqueue.event_system -> Unixqueue.group -> unit
val run : Unixqueue.event_system -> unit
val is_running : Unixqueue.event_system -> bool
val once :
Unixqueue.event_system ->
Unixqueue.group -> float -> (unit -> unit) -> unit
val weak_once :
Unixqueue.event_system ->
Unixqueue.group -> float -> (unit -> unit) -> unit
val epsilon : Unixqueue.event_system -> (unit -> unit) -> unit
module Debug :
sig
val enable : bool Stdlib.ref
val set_debug_mode : bool -> unit
val set_debug_target : Equeue.Debug.debug_target -> unit
end
end
