Module rumqttlog::waiters [−][src]
Structs
Waiter on a topic. These are used to wake connections/replicators which are caught up previously and waiting on new data.
TopicsWaiters are connections which are waiting to be notified of new topics. Notifications can sometimes be false positives for topics a connection (e.g replicator connection and new topic due to replicator data). This connection should be polled again for next notification. Having 2 waiters to prevents infinite waiter loops while trying to add connection back to waiter queue