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) Stdlib.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
include BOUNDED_QUEUE with type t := bounded queue t
val try_push_request_now : bounded queue t -> 'a Request.t -> bool
val push_request_now : infinite queue t -> 'a Request.t -> unit

Adds a message to the queue immediately.

OCaml

Innovation. Community. Security.