class Async::Queue

def enqueue(*items)
	items.each{|item| @delegate.push(item)}
rescue ClosedQueueError
	raise ClosedError, "Cannot enqueue items to a closed queue!"
end