python - 异步迭代器的类型是什么？

Question

示例(问题如下):

import asyncio
import typing as t

from aiokafka import AIOKafkaConsumer


class KafkaSimpleClient:

    ...

    async def receive(self, topic: str) -> ???:
        bootstrap_servers = ','.join(
            '{}:{}'.format(host, port)
            for host, port in self._bootstrap_servers
        )
        consumer = AIOKafkaConsumer(
            loop=asyncio.get_event_loop(),
            bootstrap_servers=bootstrap_servers,
            metadata_max_age_ms=5000,
        )
        consumer.subscribe(pattern=topic)
        await consumer.start()
        return consumer

现在，我正在努力解决 receive 的返回类型(它返回可以使用 async for x in y 进行迭代的内容。它是什么？是它是一个可等待的迭代器吗？它是可等待的迭代器吗？也许完全是别的东西？

• ??? = t.Awaitable[t.Iterator]
• ??? = t.Iterator[t.Awaitable]
• ??? =(其他)

Answer 1

Source code typing 模块毫无疑问。

async def receive(self, topic: str) -> t.AsyncIterable:

或

async def receive(self, topic: str) -> t.AsyncIterator:

如果你确定它将是严格的迭代器。