Was ist der Typ des asynchronen Iterators?

Question

Beispiel (Frage folgt.):?

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 

Jetzt bin ich mit dem Rückgabetyp receive kämpfen (es gibt etwas, das mit async for x in y iteriert werden kann, was es ist, ist es ein awaitable Iterator es ein Iterator über awaitables? Vielleicht etwas ganz anderes?

• ??? = t.Awaitable[t.Iterator]
• ??? = t.Iterator[t.Awaitable]
• ??? = (Something else)

Answer 1

Source code von typing Modul lässt keine Zweifel.

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

oder

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

, wenn Sie sicher, dass es streng Iterator sein werden.