AsyncSourceAsyncPriorityQueueWaiter

class Waiter

A waiter represents a fiber waiting to dequeue with a given priority.

Definitions

def invalidate!

Invalidate this waiter, making it unusable and detectable as abandoned.

Implementation

def invalidate!
	self.fiber = nil
end

def valid?

Check if this waiter has been invalidated.

Implementation

def valid?
	self.fiber&.alive?
end

Discussion