Added in Scala stream tasks