mordae/lazy-player
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Do not propagate computed exceptions

Browse source
This commit is contained in:
Jan Hamal Dvořák 2025-03-11 18:03:12 +01:00
parent 03c9357c01
commit ae1e361cc9
1 changed files with 0 additions and 8 deletions

8
lazy_player/reactive.py
View file

@ -13,12 +13,10 @@ T = TypeVar("T")
class Ref(Generic[T]): class Ref(Generic[T]):
_error: Exception | None
_users: WeakSet[Computed[Any]] _users: WeakSet[Computed[Any]]
_value: T _value: T
def __init__(self, initial: T): def __init__(self, initial: T):
self._error = None
self._value = initial self._value = initial
self._users = WeakSet() self._users = WeakSet()
@ -29,9 +27,6 @@ class Ref(Generic[T]):
if computed is not None: if computed is not None:
self._users.add(computed) self._users.add(computed)
if self._error is not None:
raise self._error
return self._value return self._value
@value.setter @value.setter
@ -55,7 +50,6 @@ class Computed(Ref[T]):
_update: Callable[[], T] _update: Callable[[], T]
def __init__(self, update: Callable[[], T]): def __init__(self, update: Callable[[], T]):
self._error = None
self._update = update self._update = update
self._users = WeakSet() self._users = WeakSet()
self.update() self.update()
@ -65,9 +59,7 @@ class Computed(Ref[T]):
try: try:
self.value = self._update() self.value = self._update()
self._error = None
except Exception as err: except Exception as err:
self._error = err
traceback.print_exception(err, file=sys.stderr) traceback.print_exception(err, file=sys.stderr)
finally: finally:
self._stack.reset(token) self._stack.reset(token)