def lfilter(self, b, a): " Forward only filtering" from scipy.signal import lfilter def filter_func(x): return lfilter(b, a, x, axis=0) return self.new_stream(self.vector_map(filter_func))