100% branch coverage of SGML#await

Gemfile

@@ -9,8 +9,6 @@ group :test do
 	gem "sus"
 	gem "quickdraw", github: "joeldrapper/quickdraw"
 	gem "simplecov", require: false
-	gem "async" if RUBY_ENGINE == "ruby"
-	gem "concurrent-ruby"
 	gem "selenium-webdriver"
 end
 
@@ -20,3 +18,6 @@ group :development do
 	gem "yard"
 	gem "benchmark-ips"
 end
+
+gem "concurrent-ruby"
+gem "async" if RUBY_ENGINE == "ruby"

quickdraw/sgml/await.test.rb

@@ -16,39 +16,70 @@ def view_template
 	end
 end
 
-# The Async gem only works with CRuby 3.0 and above.
-if RUBY_ENGINE == "ruby" && RUBY_VERSION[0] > "3"
-	test "async task flushes when waiting" do
+test "when given a non async task" do
+	expect { Example.new("Hello").call }.to_raise(Phlex::ArgumentError) do |error|
+		expect(error.message) == "Expected an asynchronous task / promise."
+	end
+end
+
+test "async task flushes when waiting" do
+	pid = Process.fork do
+		require "async"
+
 		Sync do
 			task = Async { sleep 0.01; "Hello" }
 			buffer = []
 			Example.new(task).call(buffer)
-			expect(buffer) == (["<h1>Before</h1>", "<h1>Hello</h1><h1>After</h1>"])
+			buffer => ["<h1>Before</h1>", "<h1>Hello</h1><h1>After</h1>"]
 		end
 	end
 
-	test "async task doesn't flush when it doesn't need to wait" do
+	pid, result = Process.wait2(pid)
+
+	assert result.success?
+end
+
+test "async task doesn't flush when it doesn't need to wait" do
+	pid = Process.fork do
+		require "async"
+
 		Sync do
 			task = Async { sleep 0.01; "Hello" }
 			task.wait
 			buffer = []
 			Example.new(task).call(buffer)
-			expect(buffer) == (["<h1>Before</h1><h1>Hello</h1><h1>After</h1>"])
+			buffer => ["<h1>Before</h1><h1>Hello</h1><h1>After</h1>"]
 		end
 	end
+
+	pid, result = Process.wait2(pid)
+
+	assert result.success?
 end
 
 test "concurrent promise flushes when waiting" do
-	task = Concurrent::Promise.execute { sleep 0.01; "Hello" }
-	buffer = []
-	Example.new(task).call(buffer)
-	expect(buffer) == (["<h1>Before</h1>", "<h1>Hello</h1><h1>After</h1>"])
+	pid = Process.fork do
+		require "concurrent"
+		task = Concurrent::Promise.execute { sleep 0.01; "Hello" }
+		buffer = []
+		Example.new(task).call(buffer)
+		buffer => ["<h1>Before</h1>", "<h1>Hello</h1><h1>After</h1>"]
+	end
+
+	pid, result = Process.wait2(pid)
+	assert result.success?
 end
 
 test "concurrent promise doesn't flush when it doesn't need to wait" do
-	task = Concurrent::Promise.execute { sleep 0.01; "Hello" }
-	task.wait
-	buffer = []
-	Example.new(task).call(buffer)
-	expect(buffer) == (["<h1>Before</h1><h1>Hello</h1><h1>After</h1>"])
+	pid = Process.fork do
+		require "concurrent"
+		task = Concurrent::Promise.execute { sleep 0.01; "Hello" }
+		task.wait
+		buffer = []
+		Example.new(task).call(buffer)
+		buffer => ["<h1>Before</h1><h1>Hello</h1><h1>After</h1>"]
+	end
+
+	pid, result = Process.wait2(pid)
+	assert result.success?
 end