

def start_receive_thread(self, nchan):
    'Start the receive thread\n\n        If the measurement has not been started, it will also be started.\n\n        Parameters\n        ----------\n        nchan : int\n            The number of channels in the data.\n        '
    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()

dataset/ETHPy150Open mne-tools/mne-python/mne/realtime/client.py RtClient.start_receive_thread/original