package eio
Effect-based direct-style IO API for OCaml
Install
dune-project
Dependency
Authors
Maintainers
Sources
eio-1.3.tbz
sha256=8ed5c13e6689f31c85dca5f12762d84b8cc0042a7b07d3e464df6eb4b72b3dfc
sha512=46e8f817f32c3316e7f35835a136ad177a295b3306351eb2efa2386482b0169a5b19ed2925b32da2a1f10d40f083fe3d588dd401908f9fec6e4a44cd68535204
doc/src/eio.utils/zzz.ml.html
Source file zzz.ml
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49
module Key = struct type t = Optint.Int63.t let compare = Optint.Int63.compare end type item = | Fiber of unit Suspended.t | Fn of (unit -> unit) module Job = struct type t = { time : Mtime.t; item : item; } let compare a b = Mtime.compare a.time b.time end module Q = Psq.Make(Key)(Job) type t = { mutable sleep_queue: Q.t; mutable next_id : Optint.Int63.t; } let create () = { sleep_queue = Q.empty; next_id = Optint.Int63.zero } let add t time item = let id = t.next_id in t.next_id <- Optint.Int63.succ t.next_id; let sleeper = { Job.time; item } in t.sleep_queue <- Q.add id sleeper t.sleep_queue; id let remove t id = t.sleep_queue <- Q.remove id t.sleep_queue let pop t ~now = match Q.min t.sleep_queue with | Some (_, { Job.time; item }) when time <= now -> begin match item with | Fiber k -> Eio.Private.Fiber_context.clear_cancel_fn k.fiber | Fn _ -> () end; t.sleep_queue <- Option.get (Q.rest t.sleep_queue); `Due item | Some (_, { Job.time; _ }) -> `Wait_until time | None -> `Nothing
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>