Using

concatMap()

seems to work for this self-contained example, but I did this with my application and I'm still having issues.