code: async def xclaim(self, name: str, group: str, consumer: str, min_idle_time: int, *stream_ids):
          
          return await self.execute_command('XCLAIM', name, group, consumer, min_idle_time, *stream_ids)
docs: [NOTICE] Not officially released yet
  
          Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
  
          :param name: name of the stream
          :param group: name of the consumer group
          :param consumer: name of the consumer
          :param min_idle_time: ms
              If the message ID (among the specified ones) exists, and its idle time greater
              or equal to min_idle_time, then the message new owner
              becomes the specified <consumer>. If the minimum idle time specified
              is zero, messages are claimed regardless of their idle time.
          :param stream_ids: