Consume the stream, processing each element sequentially on the specified ExecutionContext.
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.
Create a Publisher that runs a synchronous mapping function on this Publisher.
Create a Publisher that runs a synchronous mapping function on this Publisher. This can be used to materialize LOB values in a convenient way.
A Reactive Streams
Publisher
for database Actions.