code: async def _stream_helper(self, response, decode=False):
          
  
          if decode:
              async for chunk in json_stream(
                      self._stream_helper(response, False)):
                  yield chunk
          else:
              async with response.context as res:
                  reader = res.content
                  while True:
                      # this read call will block until we get a chunk
                      data = await reader.read(1)
                      if not data:
                          break
                      data += await reader.read(io.DEFAULT_BUFFER_SIZE)
                      yield data
docs: Generator for data coming from a chunked-encoded HTTP response.