def _map(callback, *iterables, loop=None): if any(map(inspect.isawaitable, iterables)): return map_async(callback, *iterables, loop=loop) return map(callback, *iterables)