Scala streaming + parallel collection