updates

sources/solved/async_await.ml

@@ -41,7 +41,10 @@ module Scheduler : Scheduler = struct
       fun pr main ->
         match main () with
         | v ->
-            let l = match !pr with Waiting l -> l | _ -> failwith "impossible" in
+            let l = match !pr with
+              | Waiting l -> l
+              | _ -> failwith "impossible"
+            in
             List.iter (fun k -> enqueue (fun () -> continue k v)) l;
             pr := Done v;
             dequeue ()

sources/solved/echo_async.ml

@@ -93,7 +93,8 @@ module Aio : Aio = struct
                 enqueue (fun () -> continue k (Unix.recv fd buf pos len mode))
             | Blocked _ -> failwith "impossible"
             end;
-            Hashtbl.remove ht x
+            Hashtbl.remove ht x;
+            resume ht xs
       in
       resume br rdy_rd_fds;
       resume br rdy_wr_fds;

sources/state1.ml

@@ -17,7 +17,7 @@ module State (S : sig type t end) : STATE with type t = S.t = struct
     let comp =
       match f () with
       | () -> (fun s -> ())
-      | effect Get k -> (fun (s : t) -> continue k s s)
+      | effect Get k -> (fun (s : t) -> (continue k s) s)
     in comp init
 end