docs: def enqueue_data(self, event_type, data):
          """Enqueue a data item for specific event type"""
  
          with self.lock:
              listeners = self.listeners.values()
              for listener in listeners:
                  listener.enqueue(event_type, data)
                  self.must_process = True