Performs a concurrent mapping with back pressure (won't iterate all source items if the consumer is not reading). - View it on GitHub