class Async::IO::UNIXServer

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