async def __anext__(self):
if self.response is None:<EOL><INDENT>logger.info("<STR_LIT>")<EOL>await self.connect()<EOL>return {'<STR_LIT>': True}<EOL><DEDENT>line = b'<STR_LIT>'<EOL>try:<EOL><INDENT>if self.state != NORMAL:<EOL><INDENT>if self._reconnecting:<EOL><INDENT>return await self.restart_stream()<EOL><DEDENT>else:<EOL><INDENT>return await self.init_restart()<EOL><DEDENT><DEDENT>while not line:<EOL><INDENT>if self.response.content.at_eof():<EOL><INDENT>logger.debug("<STR_LIT>")<EOL>self.state = EOF<EOL>return await self.init_restart()<EOL><DEDENT>with async_timeout.timeout(<NUM_LIT>):<EOL><INDENT>line = await self.response.content.readline()<EOL>line = line.strip(b'<STR_LIT:\r\n>')<EOL>logger.debug("<STR_LIT>" % line)<EOL><DEDENT><DEDENT>if line in rate_limit_notices:<EOL><INDENT>logger.debug("<STR_LIT>")<EOL>raise StreamLimit(line)<EOL><DEDENT>logger.debug("<STR_LIT>")<EOL>return self.loads(line)<EOL><DEDENT>except HandledErrors as e:<EOL><INDENT>logger.debug("<STR_LIT>" % (e.__class__.__name__, e))<EOL>self.state = ERROR<EOL>return await self.init_restart()<EOL><DEDENT>except ClientConnectionError:<EOL><INDENT>logger.debug("<STR_LIT>")<EOL>self.state = DISCONNECTION<EOL>return await self.init_restart()<EOL><DEDENT>except CancelledError:<EOL><INDENT>logger.debug("<STR_LIT>")<EOL>raise StopAsyncIteration<EOL><DEDENT>except Exception as e:<EOL><INDENT>self.state = ERROR<EOL>return await self.init_restart(error=e)<EOL><DEDENT>
Decode each line using json

Returns
-------
dict
    Decoded JSON data