def start_receive_thread(self, nchan):

        if self._recv_thread is None:
            self.start_measurement()

            self._recv_thread = threading.Thread(target=_buffer_recv_worker,
                                                 args=(self, nchan))
            self._recv_thread.start()
Start the receive thread
dataset/ETHPy150Open mne-tools/mne-python/mne/realtime/client.py/RtClient.start_receive_thread