class Async::Queue
def initialize(parent: nil, delegate: Thread::Queue.new)
Create a new thread-safe queue.
def initialize(parent: nil, delegate: Thread::Queue.new) @delegate = delegate @parent = parent end
def initialize(parent: nil, delegate: Thread::Queue.new) @delegate = delegate @parent = parent end