Adding collect method to Scala Observable