Reactive FP for scala