package tezos-workers

  1. Overview
  2. Docs
include QUEUE with type 'a t := 'a queue t
val push_request_and_wait : 'q queue t -> 'a Request.t -> ('a, Tezos_error_monad.TzCore.error list) result Lwt.t
val push_request : 'q queue t -> 'a Request.t -> unit Lwt.t
val pending_requests : 'a queue t -> (Tezos_base.Time.System.t * Request.view) list
val pending_requests_length : 'a queue t -> int
val push_request_now : infinite queue t -> 'a Request.t -> unit

Adds a message to the queue immediately.

OCaml

Innovation. Community. Security.