class Async::LimitedQueue

def limited?

@returns [Boolean] Whether trying to enqueue an item would block.
def limited?
	!@delegate.closed? && @delegate.size >= @delegate.max
end