Add support for IO::Event::Profiler.

Author: ioquatix

Diff for: async.gemspec

@@ -27,7 +27,7 @@ Gem::Specification.new do |spec|
 
 	spec.add_dependency "console", "~> 1.29"
 	spec.add_dependency "fiber-annotation"
-	spec.add_dependency "io-event", "~> 1.7"
+	spec.add_dependency "io-event", "~> 1.9"
 	spec.add_dependency "traces", "~> 0.15"
 	spec.add_dependency "metrics", "~> 0.12"
 end

Diff for: lib/async/scheduler.rb

@@ -42,10 +42,12 @@ def self.supported?
 		# @public Since *Async v1*.
 		# @parameter parent [Node | Nil] The parent node to use for task hierarchy.
 		# @parameter selector [IO::Event::Selector] The selector to use for event handling.
-		def initialize(parent = nil, selector: nil, worker_pool: DEFAULT_WORKER_POOL)
+		def initialize(parent = nil, selector: nil, profiler: IO::Event::Profiler.default, worker_pool: DEFAULT_WORKER_POOL)
 			super(parent)
 
 			@selector = selector || ::IO::Event::Selector.new(Fiber.current)
+			@profiler = profiler
+			
 			@interrupted = false
 
 			@blocked = 0
@@ -492,13 +494,19 @@ def stop
 		def run(...)
 			Kernel.raise ClosedError if @selector.nil?
 
-			initial_task = self.async(...) if block_given?
-			
-			self.run_loop do
-				run_once
+			begin
+				@profiler&.start
+				
+				initial_task = self.async(...) if block_given?
+				
+				self.run_loop do
+					run_once
+				end
+				
+				return initial_task
+			ensure
+				@profiler&.stop
 			end
-			
-			return initial_task
 		end
 
 		# Start an asynchronous task within the specified reactor. The task will be executed until the first blocking call, at which point it will yield and and this method will return.

Diff for: test/io.rb

@@ -45,12 +45,14 @@
 		it "can write with timeout" do
 			skip_unless_constant_defined(:TimeoutError, IO)
 
+			big = "x" * 1024 * 1024
+			
 			input, output = IO.pipe
 			output.timeout = 0.001
 
 			expect do
 				while true
-					output.write("Hello")
+					output.write(big)
 				end
 			end.to raise_exception(::IO::TimeoutError)
 		end