Update NadTalker to conform to new BaseThread interface
This commit is contained in:
parent
a68bd4b475
commit
feff24cd28
@ -40,7 +40,7 @@ class NadMixer(BaseMixer):
|
|||||||
super(NadMixer, self).__init__(*args, **kwargs)
|
super(NadMixer, self).__init__(*args, **kwargs)
|
||||||
self._volume = None
|
self._volume = None
|
||||||
self._pipe, other_end = Pipe()
|
self._pipe, other_end = Pipe()
|
||||||
NadTalker(pipe=other_end).start()
|
NadTalker(self.backend.core_queue, pipe=other_end).start()
|
||||||
|
|
||||||
def _get_volume(self):
|
def _get_volume(self):
|
||||||
return self._volume
|
return self._volume
|
||||||
@ -72,8 +72,9 @@ class NadTalker(BaseThread):
|
|||||||
# Volume in range 0..VOLUME_LEVELS. :class:`None` before calibration.
|
# Volume in range 0..VOLUME_LEVELS. :class:`None` before calibration.
|
||||||
_nad_volume = None
|
_nad_volume = None
|
||||||
|
|
||||||
def __init__(self, pipe=None):
|
def __init__(self, core_queue, pipe=None):
|
||||||
super(NadTalker, self).__init__(name='NadTalker')
|
super(NadTalker, self).__init__(core_queue)
|
||||||
|
self.name = u'NadTalker'
|
||||||
self.pipe = pipe
|
self.pipe = pipe
|
||||||
self._device = None
|
self._device = None
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user