def force_future(entity, loop=None):
if inspect.isawaitable(entity):
return entity
future = asyncio.Future(loop=loop)
future.set_result(entity)
return future
微信
公众号
扫码关注公众号