Is there some cross-over happening between reactive programming a la akka and "functional streaming" a la scalding?