class Async::Reactor

def run(*arguments, **options, &block)

Run the reactor until all tasks are finished. Proxies arguments to {#async} immediately before entering the loop, if a block is provided. 
def run(*arguments, **options, &block)
	raise RuntimeError, 'Reactor has been closed' if @selector.nil?
	
	@scheduler&.set!
	
	initial_task = self.async(*arguments, **options, &block) if block_given?
	
	while self.run_once
		# Round and round we go!
	end
	
	return initial_task
ensure
	@scheduler&.clear!
	logger.debug(self) {"Exiting run-loop because #{$! ? $! : 'finished'}."}
end