Method QueueItem

pkg/utilds/quickreorderqueue.go:116–152

(sessionId string, seqNum int, data T)

}

func (q *QuickReorderQueue[T]) QueueItem(sessionId string, seqNum int, data T) error {
	q.lock.Lock()
	defer q.lock.Unlock()

	if q.closed {
		return fmt.Errorf("ReorderQueue is closed, cannot queue new item")
	}

	if len(q.buffer)+len(q.outCh) >= cap(q.outCh) {
		return fmt.Errorf("queue is full, cannot accept new items, cap: %d", cap(q.outCh))
	}

	q.ensureSessionTs_withlock(sessionId)

	cmp := q.cmpSessionSeq_withlock(sessionId, seqNum, q.currentSessionId, q.nextSeqNum)

	if cmp < 0 || seqNum == 0 || sessionId == "" {
		q.outCh <- data
		return nil
	}

	if cmp == 0 {
		q.outCh <- data
		q.nextSeqNum++
		q.processBuffer_withlock()
		return nil
	}

	q.buffer = append(q.buffer, queuedItem[T]{
		sessionId: sessionId,
		seqNum:    seqNum,
		data:      data,
		timestamp: time.Now(),
	})
	q.ensureTimer_withlock()
	return nil
}

func (q *QuickReorderQueue[T]) processBuffer_withlock() {
	if len(q.buffer) == 0 {