code: async def xack(self, name: str, group: str, stream_id: str) -> int:
          
          return await self.execute_command('XACK', name, group, stream_id)
docs: [NOTICE] Not officially released yet
  
          XACK is the command that allows a consumer to mark a pending message as correctly processed.
  
          :param name: name of the stream
          :param group: name of the consumer group
          :param stream_id: id of the entry the consumer wants to mark
          :return: number of entry marked