Fixed scala's Observable