def read_raw_buffer(self, nchan):
        tag, this_buff = _recv_tag_raw(self._data_sock)

        # skip tags until we get a data buffer
        while tag.kind != FIFF.FIFF_DATA_BUFFER:
            tag, this_buff = _recv_tag_raw(self._data_sock)

        buff = StringIO(this_buff)
        tag = read_tag(buff)
        raw_buffer = tag.data.reshape(-1, nchan).T

        return raw_buffer
Integrated implementation sending run results back to central store.
dataset/ETHPy150Open mne-tools/mne-python/mne/realtime/client.py/RtClient.read_raw_buffer--crossover with--dataset/ETHPy150Open chapmanb/bcbio-nextgen-vm/bcbiovm/ship/pack.py/send_run_integrated