class Concurrent::Async::AsyncDelegator

def initialize(delegate)

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