set prevent

This commit is contained in:
Will McGugan
2023-02-23 15:34:02 +00:00
parent c2ea074f4a
commit ba30e0dd66
2 changed files with 9 additions and 3 deletions

View File

@@ -582,6 +582,8 @@ class MessagePump(metaclass=MessagePumpMeta):
return False return False
if not self.check_message_enabled(message): if not self.check_message_enabled(message):
return True return True
if self._prevent_message_types_stack:
message._prevent.update(self._prevent_message_types_stack[-1])
await self._message_queue.put(message) await self._message_queue.put(message)
return True return True
@@ -620,6 +622,8 @@ class MessagePump(metaclass=MessagePumpMeta):
return False return False
if not self.check_message_enabled(message): if not self.check_message_enabled(message):
return False return False
if self._prevent_message_types_stack:
message._prevent.update(self._prevent_message_types_stack[-1])
self._message_queue.put_nowait(message) self._message_queue.put_nowait(message)
return True return True

View File

@@ -237,9 +237,11 @@ class Reactive(Generic[ReactiveType]):
events.Callback( events.Callback(
sender=obj, sender=obj,
callback=partial(await_watcher, watch_result), callback=partial(await_watcher, watch_result),
prevent=obj._prevent_message_types_stack[0] prevent=(
if obj._prevent_message_types_stack obj._prevent_message_types_stack[0]
else None, if obj._prevent_message_types_stack
else None
),
) )
) )