def __init__(self, host, port):
self._queue = queue.Queue()<EOL>self._buffer = queue.Queue()<EOL>self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)<EOL>self._socket.connect((host, port))<EOL>self._source = GstreamerAppSrc()<EOL>self._last_sync = time.time()<EOL>self._connected = False<EOL>self._buffered = False<EOL>threading.Thread(target=self._read_socket, daemon=True).start()<EOL>threading.Thread(target=self._write_socket, daemon=True).start()<EOL>threading.Thread(target=self._play, daemon=True).start()<EOL>_LOGGER.info('<STR_LIT>', host, port)<EOL>
Setup.