Using es.through instead of Stream.Transform