code: def xread_group(self, group_name, consumer_name, streams, timeout=0,
                      count=None, latest_ids=None):
          
          args = self._xread(streams, timeout, count, latest_ids)
          fut = self.execute(
              b'XREADGROUP', b'GROUP', group_name, consumer_name, *args
          )
          return wait_convert(fut, parse_messages_by_stream)
docs: Perform a blocking read on the given stream as part of a consumer group
  
          :raises ValueError: if the length of streams and latest_ids do
                              not match