listener.py 文件源码

def _process(self):

        try:
            # Receive UDP packets.
            recv_string = self.acq_socket.recv(self.buf_size, socket.MSG_WAITALL)
            # Change data format.
            batch = self.read_live_udp_packet(recv_string, self.acq_dtype, self.acq_nb_chan, self.dtype)
            # Send output.
            self.output.send(batch)
            # Increment counter for buffer receptions.
            self.step_nb += 1
        except:
            raise NotImplementedError()

        return