代码拉取完成,页面将自动刷新
set_results
on cancelled future #133ssl_options
for coonect and connect_robustamqp
and amqps
message_kwargs
for worker patterntimeout
parameter for Exchange.declare
__all__
rubust_connect
mode.python_requires=">3.4.*, <4",
instead of if sys.version_info
in the setup.py
TimeoutError
to the asyncio.TimeoutError
extras_require = {':python_version': 'typing >= 3.5.3',
to the setup.py
aio_pika.patterns
submodule
aio_pika.patterns.RPC
- RPC patternaio_pika.patterns.Master
- Master/Worker patternpassive
argument for excahngeChannel.is_closed
propertyChannel.close
just return None
when channel already closedConnection
might be used in async with
expressionQueue
might be used in async with
and returns QueueIterator
Queue.iterator()
methodQueueIterator.close()
returns asyncio.Future
instead of asyncio.Task
QueueIterator
in async for
expressionconnect_robust
is a coroutine
instead of function which returns a coroutine
(PyCharm type checking display warning instead)Conneciton.close
returns asyncio.Task
instead coroutine.connect_robust
now is function instead of partial
.此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。