Similarly here, Iteratee.flatten is using the default execution context, it possibly makes sense to flatten the iteratee manually, and pass in a same thread executor to the flatMap method used there?