wrapper for streams1 transforms to prevent losing data
2.1.3