From 41ad73a3ed4604abc87c26f5dabc65c23e060b83 Mon Sep 17 00:00:00 2001
From: Benjamin Canou <benjamin@canou.fr>
Date: Tue, 2 Jan 2018 17:07:11 +0100
Subject: [PATCH] Utils: remove `Lwt_utils.queue`

---
 src/lib_stdlib_lwt/lwt_utils.ml  | 29 -----------------------------
 src/lib_stdlib_lwt/lwt_utils.mli |  1 -
 2 files changed, 30 deletions(-)

diff --git a/src/lib_stdlib_lwt/lwt_utils.ml b/src/lib_stdlib_lwt/lwt_utils.ml
index c0cd0557b..7e4f807ff 100644
--- a/src/lib_stdlib_lwt/lwt_utils.ml
+++ b/src/lib_stdlib_lwt/lwt_utils.ml
@@ -91,35 +91,6 @@ let trigger () : (unit -> unit) * (unit -> unit Lwt.t) =
   in
   trigger, wait
 
-type 'a queue =
-  | Absent
-  | Present of 'a list ref
-  | Waiting of ('a list Lwt.t * 'a list Lwt.u)
-
-let queue () : ('a -> unit) * (unit -> 'a list Lwt.t) =
-  let state = ref Absent in
-  let queue v =
-    match !state with
-    | Absent -> state := Present (ref [v])
-    | Present r -> r := v :: !r
-    | Waiting (_waiter, wakener) ->
-        state := Absent;
-        Lwt.wakeup wakener [v]
-  in
-  let wait () =
-    match !state with
-    | Absent ->
-        let waiter, wakener = Lwt.wait () in
-        state := Waiting (waiter, wakener) ;
-        waiter
-    | Present r ->
-        state := Absent;
-        Lwt.return (List.rev !r)
-    | Waiting (waiter, _wakener) ->
-        waiter
-  in
-  queue, wait
-
 (* A worker launcher, takes a cancel callback to call upon *)
 let worker name ~run ~cancel =
   let stop = LC.create () in
diff --git a/src/lib_stdlib_lwt/lwt_utils.mli b/src/lib_stdlib_lwt/lwt_utils.mli
index 1fc73e561..41e8b9766 100644
--- a/src/lib_stdlib_lwt/lwt_utils.mli
+++ b/src/lib_stdlib_lwt/lwt_utils.mli
@@ -23,7 +23,6 @@ val worker:
   unit Lwt.t
 
 val trigger: unit -> (unit -> unit) * (unit -> unit Lwt.t)
-val queue: unit -> ('a -> unit) * (unit -> 'a list Lwt.t)
 val sort: ('a -> 'a -> int Lwt.t) -> 'a list -> 'a list Lwt.t
 
 val read_bytes: