Alternate clean+idiomatic Scala API for the RxJava reactive extensions library