class_docstr: Iterator to allow async iteration of blocking/non-blocking iterator from the Client
docstr: Async request iterator
  
  :param iterator: request iterator
  :param request_counter: counter of the numbers of request being handled at a given moment
  :param prefetch: The max amount of requests to be handled at a given moment (0 disables feature)
  :param iterate_sync_in_thread: if True, blocking iterators will call __next__ in a Thread.
docstr_tok: ["Async","request","iterator",":","param","iterator",":","request","iterator",":","param","request_counter",":","counter","of","the","numbers","of","request","being","handled","at","a","given","moment",":","param","prefetch",":","The","max","amount","of","requests","to","be","handled","at","a","given","moment","(","0","disables","feature",")",":","param","iterate_sync_in_thread",":","if","True",",","blocking","iterators","will","call","__next__","in","a","Thread","."]
code: def __init__(
      self,
      iterator: Union[Iterator, AsyncIterator],
      request_counter: Optional[_RequestsCounter] = None,
      prefetch: int = 0,
      iterate_sync_in_thread: bool = True,
  ) -> None:
      """Async request iterator
  
      :param iterator: request iterator
      :param request_counter: counter of the numbers of request being handled at a given moment
      :param prefetch: The max amount of requests to be handled at a given moment (0 disables feature)
      :param iterate_sync_in_thread: if True, blocking iterators will call __next__ in a Thread.
      """
      self.iterator = iterator
      self._request_counter = request_counter
      self._prefetch = prefetch
      self._iterate_sync_in_thread = iterate_sync_in_thread
  
file_path: jina/jina/serve/stream/helper.py
imports: import asyncio
  from typing import AsyncIterator, Iterator, Optional, Union
  from jina.helper import get_or_reuse_loop
label_desc: Use image node_id 1 to create a new AsyncRequestsIterator object  with example: obj = AsyncRequestsIterator(iterator, request_counter, prefetch, iterate_sync_in_thread)