There's no reason why [filter](https://github.com/nerevu/riko/blob/a460dd3b19bef5d2f5e4daa2736a9027f40b92fa/riko/modules/filter.py#L141-L155) needs access to the entire stream. It should be able to operate on individual items.
There's no reason why filter needs access to the entire stream. It should be able to operate on individual items.