class Async::Wrapper

def initialize(io, reactor = nil)

Parameters:
  • bound (Boolean) -- whether the underlying socket will be closed if the wrapper is closed.
  • reactor (Reactor) -- the reactor that is managing this wrapper, or not specified, it's looked up by way of {Task.current}.
  • io () -- the native object to wrap.
def initialize(io, reactor = nil)
	@io = io
	
	@reactor = reactor || Task.current.reactor
	@monitor = nil
end