reactive programming in Scala source code & examples