Struct rumqttlog::waiters::DataWaiters [−][src]
pub struct DataWaiters { /* fields omitted */ }
Expand description
Waiter on a topic. These are used to wake connections/replicators which are caught up previously and waiting on new data.
Implementations
Register data waiter
Remove a connection from waiters