Method Clear

pkg/flushqueues/exclusivequeues.go:48–50

Clear unblocks the requested op. This should be called only after a flush has been successful

(op T)

// Clear unblocks the requested op.  This should be called only after a flush has been successful
func (f *ExclusiveQueues[T]) Clear(op T) {
	f.activeKeys.Delete(op.Key())
}

func (f *ExclusiveQueues[T]) IsEmpty() bool {
	length := 0