We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent af14c58 commit c94182cCopy full SHA for c94182c
message_bus_tools.py
@@ -95,6 +95,7 @@ def unsubscribe(self, event_type, uid):
95
def publish(self, event_type: Message, data):
96
self.lock_count += 1
97
if event_type in self.subscribers:
98
+
99
sorted_callbacks = sorted([(x[1][0], x[1][1]) for x in self.subscribers[event_type].items()], key=lambda x: x[1])
100
for callback, priority in sorted_callbacks:
101
if self.debug:
0 commit comments