class Concurrent::Async::AsyncDelegator
def initialize(delegate)
-
delegate
(Object
) -- the object to wrap and delegate method calls to
def initialize(delegate) super() @delegate = delegate @queue = [] @executor = Concurrent.global_io_executor end