def foreach[U](f: T => U)(implicit ec: ExecutionContext): Future[Unit]
Consume the stream, processing each element sequentially on the specified ExecutionContext.
The resulting Future completes when all elements have been processed or an error was
signaled.
Consume the stream, processing each element sequentially on the specified ExecutionContext.
The resulting Future completes when all elements have been processed or an error was
signaled.