class Async::Wrapper
def initialize(io, reactor = nil)
-
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