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
评论列表
文章目录