Module MakeSingle.Queue

Instrumented queue tracing a request handling from the moment it is being pushed to a worker’s pending queue.

val push_request_and_wait : 'a queue t -> ('b, 'c) Raw_request.t -> ('b, 'c message_error) Stdlib.result Lwt.t
val push_request : 'a queue t -> ('b, 'c) Raw_request.t -> bool Lwt.t