blackbull.mqtt.mailbox¶
blackbull.mqtt.mailbox
¶
MQTT-private FIFO bounded by message count and retained wire-size charge.
The queue owns waiting messages, not the consumer's active message or the producer's single admission candidate. Closing wakes waiters without requiring room for a sentinel. No task is created for a blocked admission.