filter.py 文件源码

def _process(self):

        # Receive input data.
        batch = self.input.receive()

        self._measure_time('start', frequency=100)

        # Process data.
        for i in xrange(self.nb_channels):
            batch[:, i], self.z[i] = signal.lfilter(self.b, self.a, batch[:, i], zi=self.z[i])
            batch[:, i] -= np.median(batch[:, i])
        if self.remove_median:
            global_median = np.median(batch, 1)
            for i in xrange(self.nb_channels):
                batch[:, i] -= global_median

        # Send output data.
        self.output.send(batch)

        self._measure_time('end', frequency=100)

        return