From c076fb75d40b85b593bd569eaf7f6e13ab95cdd8 Mon Sep 17 00:00:00 2001 From: Stein Magnus Jodal Date: Fri, 26 Oct 2012 23:05:53 +0200 Subject: [PATCH] Replace Pykka internals misuse with proxies --- mopidy/frontends/mpd/actor.py | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/mopidy/frontends/mpd/actor.py b/mopidy/frontends/mpd/actor.py index 0c73bc2b..f69334b5 100644 --- a/mopidy/frontends/mpd/actor.py +++ b/mopidy/frontends/mpd/actor.py @@ -48,14 +48,9 @@ class MpdFrontend(pykka.ThreadingActor, CoreListener): process.stop_actors_by_class(session.MpdSession) def send_idle(self, subsystem): - # FIXME this should be updated once pykka supports non-blocking calls - # on proxies or some similar solution - pykka.ActorRegistry.broadcast({ - 'command': 'pykka_call', - 'attr_path': ('on_idle',), - 'args': [subsystem], - 'kwargs': {}, - }, target_class=session.MpdSession) + listeners = pykka.ActorRegistry.get_by_class(session.MpdSession) + for listener in listeners: + getattr(listener.proxy(), 'on_idle')(subsystem) def playback_state_changed(self, old_state, new_state): self.send_idle('player')