Fixed bug preventing the Scala Stream Collector from creating a new stream