Fix test race on IO#write.

Author: ioquatix

lib/async/task.rb

@@ -136,7 +136,7 @@ def to_s
 
 		# @deprecated Prefer {Kernel#sleep} except when compatibility with `stable-v1` is required.
 		def sleep(duration = nil)
-			warn("`Async::Task#sleep` is deprecated, use `Kernel#sleep` instead.", uplevel: 1, category: :deprecated) if $VERBOSE
+			Kernel.warn("`Async::Task#sleep` is deprecated, use `Kernel#sleep` instead.", uplevel: 1, category: :deprecated) if $VERBOSE
 
 			super
 		end

test/async/limited_queue.rb

@@ -87,17 +87,16 @@ def before
 	with "#close" do
 		it "signals tasks waiting to enqueue items when closed" do
 			queue.enqueue(:item1)
-
+			
 			# This task will block as the queue is full:
 			waiting_task = reactor.async do
-				queue.enqueue(:item2)
+				expect do
+					queue.enqueue(:item2)
+				end.to raise_exception(Async::Queue::ClosedError)
 			end
-
+			
 			queue.close
-
-			expect do
-				waiting_task.wait
-			end.to raise_exception(Async::Queue::ClosedError)
+			waiting_task.wait
 		end
 	end
 end

test/async/task.rb

@@ -75,11 +75,13 @@
 
 	with "#current?" do
 		it "can check if it is the currently running task" do
+			was_current = nil
+			
 			task = reactor.async do |task|
-				expect(task).to be(:current?)
-				sleep(0.1)
+				was_current = task.current?
 			end
 
+			expect(was_current).to be == true
 			expect(task).not.to be(:current?)
 		end
 	end
@@ -124,7 +126,8 @@
 			reactor.run do
 				expect do
 					reactor.async do |task|
-						expect(task).to receive(:warn).and_return(nil)
+						# Ensure the wait is executed before raising the exception:
+						task.yield
 
 						raise "boom"
 					end.wait
@@ -154,19 +157,19 @@
 		it "can consume exceptions" do
 			task = nil
 
-			expect do
-				task = reactor.async do |task|
-					expect(task).to receive(:warn).and_return(nil)
-					
-					raise "boom"
-				end
-			end.not.to raise_exception
-			
 			reactor.run do
 				expect do
-					task.wait
-				end.to raise_exception(RuntimeError, message: be =~ /boom/)
+					task = reactor.async do |task|
+						expect(task).to receive(:warn).and_return(nil)
+						
+						raise "boom"
+					end
+				end.not.to raise_exception
 			end
+			
+			expect do
+				task.wait
+			end.to raise_exception(RuntimeError, message: be =~ /boom/)
 		end
 
 		it "won't consume non-StandardError exceptions" do
@@ -508,6 +511,7 @@
 
 		it "can stop resumed task" do
 			items = [1, 2, 3]
+			value = nil
 
 			reactor.run do
 				condition = Async::Condition.new
@@ -520,11 +524,11 @@
 				end
 
 				value = condition.wait # (2) value = Fiber.yield
-				expect(value).to be == 3
 				producer.stop # (5) [producer is resumed already] producer.stop
 			end
 
 			expect(items).to be == [1, 2]
+			expect(value).to be == 3
 		end
 
 		it "can stop a child task with transient children" do
@@ -720,7 +724,7 @@ def sleep_forever
 			end
 
 			innocent_task = reactor.async do |task|
-				expect{error_task.wait}.to raise_exception(RuntimeError, message: be =~ /boom/)
+				error_task.wait
 			end
 
 			expect do
@@ -729,6 +733,10 @@ def sleep_forever
 
 			expect(error_task).to be(:finished?)
 			expect(innocent_task).to be(:finished?)
+			
+			expect do
+				innocent_task.wait
+			end.to raise_exception(RuntimeError, message: be =~ /boom/)
 		end
 
 		it "will not raise exception values returned by the task" do