Reactive data processing in Scala on Appengine