Java/Scala Observable comparison