def __init__(self, pipeline_string):
        """Initialize player wrapper."""
        self._manager = multiprocessing.Manager().dict({
            ATTR_STATE: STATE_IDLE,
            ATTR_DURATION: None,
            ATTR_POSITION: None,
            ATTR_VOLUME: None,
            ATTR_ARTIST: None,
            ATTR_ALBUM: None,
            ATTR_TITLE: None,
            ATTR_URI: None
        })
        self._task_queue = multiprocessing.Queue()
        self._media_queue = multiprocessing.Queue()
        _LOGGER.info('starting gstreamer')
        self._player = GstreamerProcess(self._manager, self._task_queue,
                                        self._media_queue, pipeline_string)
        self._player.start()
def __init__ ( self , pipeline_string ) : self . _manager = multiprocessing . Manager ( ) . dict ( { ATTR_STATE : STATE_IDLE , ATTR_DURATION : None , ATTR_POSITION : None , ATTR_VOLUME : None , ATTR_ARTIST : None , ATTR_ALBUM : None , ATTR_TITLE : None , ATTR_URI : None } ) self . _task_queue = multiprocessing . Queue ( ) self . _media_queue = multiprocessing . Queue ( ) _LOGGER . info ( 'starting gstreamer' ) self . _player = GstreamerProcess ( self . _manager , self . _task_queue , self . _media_queue , pipeline_string ) self . _player . start ( )
Initialize player wrapper.