Async_unix__.Interruptor
type t
val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t
include Core.Invariant.S with type t := t
val invariant : t Base__.Invariant_intf.inv
val create : create_fd:(Async_unix__.Raw_fd.Kind.t -> Core.Unix.File_descr.t -> Core.Info.t -> Async_unix__.Raw_fd.t) -> t
val read_fd : t -> Async_unix__.Raw_fd.t
val thread_safe_interrupt : t -> unit
thread_safe_interrupt t causes read_fd t to become ready for reading.
thread_safe_interrupt t
read_fd t
val clear : t -> unit
clear t causes read_fd t to become not ready for reading. It is guaranteed that any calls to thread_safe_interrupt after clear t returns (and prior to another call to clear t) will cause read_fd to become ready for reading.
clear t
thread_safe_interrupt
read_fd