Method discardDoneAtFront

internal/pool/want_conn.go:101–115

()

}

func (q *wantConnQueue) discardDoneAtFront() int {
	q.mu.Lock()
	defer q.mu.Unlock()
	count := 0
	for len(q.items) > 0 {
		if q.items[0].isOngoing() {
			break
		}

		q.items = q.items[1:]
		count++
	}

	return count
}