class Async::Scheduler

def from_io(io)

def from_io(io)
rs[io] ||= Wrapper.new(io, @reactor)