mecca ~master (2021-09-12T14:37:04Z)

BlockingQueue.push

mecca reactor sync queue BlockingQueue

Add an item to the queue.

  1. void push(Type item, Timeout timeout)
    struct BlockingQueue(Type, ushort MaxItems)
    @safe @nogc
    @notrace
    void
    push
    (
    Type item
    ,
    Timeout timeout = Timeout.infinite
    )
  2. Type* push(Timeout timeout)

Parameters

item Type

item to add.

timeout Timeout

how long to wait if no room to add immediately.

Meta

Source

See Implementation

mecca reactor sync queue BlockingQueue functionsproperties

Page generated by adrdox