class Async::IO::UNIXServer

def accept
	peer = async_send(:accept_nonblock)
	
	if block_given?
		wrapper = UNIXSocket.new(peer, self.reactor)
		
		begin
			yield wrapper
		ensure
			wrapper.close
		end
	else
		return UNIXSocket.new(peer, self.reactor)
	end
end