stream: add a concurrency option to services, limiting parallel callbacks