mpd: Switch MpdSession to using on_event and re-use listener helper.
This commit is contained in:
parent
593f4e295b
commit
7ab2665292
@ -4,7 +4,7 @@ import logging
|
||||
|
||||
import pykka
|
||||
|
||||
from mopidy import exceptions, zeroconf
|
||||
from mopidy import exceptions, listener, zeroconf
|
||||
from mopidy.core import CoreListener
|
||||
from mopidy.internal import encoding, network, process
|
||||
from mopidy.mpd import session, uri_mapper
|
||||
@ -57,9 +57,7 @@ class MpdFrontend(pykka.ThreadingActor, CoreListener):
|
||||
process.stop_actors_by_class(session.MpdSession)
|
||||
|
||||
def send_idle(self, subsystem):
|
||||
listeners = pykka.ActorRegistry.get_by_class(session.MpdSession)
|
||||
for listener in listeners:
|
||||
getattr(listener.proxy(), 'on_idle')(subsystem)
|
||||
listener.send(session.MpdSession, subsystem)
|
||||
|
||||
def playback_state_changed(self, old_state, new_state):
|
||||
self.send_idle('player')
|
||||
|
||||
@ -41,7 +41,7 @@ class MpdSession(network.LineProtocol):
|
||||
|
||||
self.send_lines(response)
|
||||
|
||||
def on_idle(self, subsystem):
|
||||
def on_event(self, subsystem):
|
||||
self.dispatcher.handle_idle(subsystem)
|
||||
|
||||
def decode(self, line):
|
||||
|
||||
@ -10,7 +10,7 @@ from tests.mpd import protocol
|
||||
class IdleHandlerTest(protocol.BaseTestCase):
|
||||
|
||||
def idle_event(self, subsystem):
|
||||
self.session.on_idle(subsystem)
|
||||
self.session.on_event(subsystem)
|
||||
|
||||
def assertEqualEvents(self, events): # noqa: N802
|
||||
self.assertEqual(set(events), self.context.events)
|
||||
|
||||
Loading…
Reference in New Issue
Block a user