andpp/mopidy
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

GstreamerProcess: Add method for processing msgs from core

Browse Source
This commit is contained in:
Stein Magnus Jodal 2010-08-11 19:01:46 +02:00
parent 93e6aa13cf
commit 420bdee1a0
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
mopidy/outputs/gstreamer.py
View File

@ -42,7 +42,8 @@ class GStreamerProcess(BaseProcess):
# Setup bus and message processor
self.gst_bus = self.gst_pipeline.get_bus()
self.gst_bus.add_signal_watch()
self.gst_bus_id = self.gst_bus.connect('message', self.process_message)
self.gst_bus_id = self.gst_bus.connect('message',
self.process_gst_message)
# Bin for playing audio URIs
self.gst_uri_src = gst.element_factory_make('uridecodebin', 'uri_src')
@ -72,7 +73,12 @@ class GStreamerProcess(BaseProcess):
# TODO Handle commands
self.gobject_context.iteration(True)
def process_message(self, bus, message):
def process_core_message(self, message):
"""Processes messages from the rest of Mopidy."""
pass # TODO
def process_gst_message(self, bus, message):
"""Processes message from GStreamer."""
if message.type == gst.MESSAGE_EOS:
pass # TODO Handle end of track/stream
elif message.type == gst.MESSAGE_ERROR: