检查 call 是否是一个异步生成器函数
(call: Callable[..., Any])
| 238 | |
| 239 | |
| 240 | def is_async_gen_callable(call: Callable[..., Any]) -> bool: |
| 241 | """检查 call 是否是一个异步生成器函数""" |
| 242 | if inspect.isasyncgenfunction(call): |
| 243 | return True |
| 244 | func_ = getattr(call, "__call__", None) |
| 245 | return inspect.isasyncgenfunction(func_) |
| 246 | |
| 247 | |
| 248 | def run_sync(call: Callable[P, R]) -> Callable[P, Coroutine[None, None, R]]: |
no outgoing calls