async closures are expected to be stabilized soon, see https://github.com/rust-lang/rust/pull/132706 we should prepare the `ConcurrentStream` API to accept the new `AsyncFn` family, named `map`, `for_each`, and `try_for_each`.