async def _on_push_data(self, data_bytes):
logger.debug('<STR_LIT>'.format(data_bytes))<EOL>for chunk in self._chunk_parser.get_chunks(data_bytes):<EOL><INDENT>if not self._is_connected:<EOL><INDENT>if self._on_connect_called:<EOL><INDENT>self._is_connected = True<EOL>await self.on_reconnect.fire()<EOL><DEDENT>else:<EOL><INDENT>self._on_connect_called = True<EOL>self._is_connected = True<EOL>await self.on_connect.fire()<EOL><DEDENT><DEDENT>container_array = json.loads(chunk)<EOL>for inner_array in container_array:<EOL><INDENT>array_id, data_array = inner_array<EOL>logger.debug('<STR_LIT>',<EOL>array_id, data_array)<EOL>await self.on_receive_array.fire(data_array)<EOL><DEDENT><DEDENT>
Parse push data and trigger events.