ya2 · news · projects · code · about

some cleaning
[pmachines.git] / ya2 / patterns / observer.py
index 7c49116b459eb695902524f600f2dbf0173d39bc..963d82288b78c2e39e868c7c80afd6192377fac2 100644 (file)
@@ -16,7 +16,8 @@ class Subject:
     def attach(self, obs_meth, sort=10, rename='', args=None):
         args = args or []
         onm = rename or obs_meth.__name__
-        if onm not in self.observers: self.observers[onm] = []
+        if onm not in self.observers:
+            self.observers[onm] = []
         self.observers[onm] += [ObsInfo(obs_meth, sort, args)]
         sorted_obs = sorted(self.observers[onm], key=lambda obs: obs.sort)
         self.observers[onm] = sorted_obs
@@ -30,11 +31,13 @@ class Subject:
             onm = obs_meth.__name__
             observers = [obs for obs in self.observers[onm]
                          if obs.mth == obs_meth]
-        if not observers: raise Exception
+        if not observers:
+            raise Exception
         list(map(self.observers[onm].remove, observers))
 
     def notify(self, meth, *args, **kwargs):
-        if meth not in self.observers: return  # no obs for this notification
+        if meth not in self.observers:
+            return  # no obs for this notification
         for obs in self.observers[meth][:]:
             if obs in self.observers[meth]:  # if an obs removes another one
                 try:
@@ -42,13 +45,16 @@ class Subject:
                     obs.mth(*act_args, **kwargs)
                 except SystemError:
                     print('Quit')
-                    import sys; sys.exit()
+                    import sys
+                    sys.exit()
 
     def observing(self, obs_meth):
-        if callable(obs_meth): obs_meth = obs_meth.__name__
+        if callable(obs_meth):
+            obs_meth = obs_meth.__name__
         return obs_meth in self.observers and self.observers[obs_meth]
 
     def destroy(self): self.observers = None
 
 
-class Observer: pass
+class Observer:
+    pass