Module Opentelemetry_client_sync.Sync_queueSource

Simple blocking queue

Sourcetype 'a t
Sourceval create : unit -> _ t
Sourceexception Closed
Sourceval push : 'a t -> 'a -> unit

push q x pushes x into q, and returns ().

  • raises Closed

    if close q was previously called.

Sourceval pop : 'a t -> 'a

pop q pops the next element in q. It might block until an element comes.

  • raises Closed

    if the queue was closed before a new element was available.

Sourceval pop_all : 'a t -> 'a Queue.t -> unit

pop_all q into pops all the elements of q and moves them into into. if no element is available, it will block until it successfully transfers at least one item to into.

  • raises Closed

    if the queue was closed before a new element was available.

Sourceval close : _ t -> unit

Close the queue, meaning there won't be any more push allowed.