Migrate tests from rspec -> sus.

fixtures/async/http/body/a_writable_body.rb

@@ -0,0 +1,110 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2023, by Samuel Williams.
+
+require 'protocol/http/body/deflate'
+
+module Async
+	module HTTP
+		module Body
+			AWritableBody = Sus::Shared("a writable body") do
+				it "can write and read data" do
+					3.times do |i|
+						body.write("Hello World #{i}")
+						expect(body.read).to be == "Hello World #{i}"
+					end
+				end
+
+				it "can buffer data in order" do
+					3.times do |i|
+						body.write("Hello World #{i}")
+					end
+
+					3.times do |i|
+						expect(body.read).to be == "Hello World #{i}"
+					end
+				end
+
+				with '#join' do
+					it "can join chunks" do
+						3.times do |i|
+							body.write("#{i}")
+						end
+
+						body.close
+
+						expect(body.join).to be == "012"
+					end
+				end
+
+				with '#each' do
+					it "can read all data in order" do
+						3.times do |i|
+							body.write("Hello World #{i}")
+						end
+
+						body.close
+
+						3.times do |i|
+							chunk = body.read
+							expect(chunk).to be == "Hello World #{i}"
+						end
+					end
+
+					it "can propagate failures" do
+						reactor.async do
+							expect do
+								body.each do |chunk|
+									raise RuntimeError.new("It was too big!")
+								end
+							end.to raise_exception(RuntimeError, message: be =~ /big/)
+						end
+
+						expect{
+							body.write("Beep boop") # This will cause a failure.
+							::Async::Task.current.yield
+							body.write("Beep boop") # This will fail.
+						}.to raise_exception(RuntimeError, message: be =~ /big/)
+					end
+
+					it "can propagate failures in nested bodies" do
+						nested = ::Protocol::HTTP::Body::Deflate.for(body)
+
+						reactor.async do
+							expect do
+								nested.each do |chunk|
+									raise RuntimeError.new("It was too big!")
+								end
+							end.to raise_exception(RuntimeError, message: be =~ /big/)
+						end
+
+						expect{
+							body.write("Beep boop") # This will cause a failure.
+							::Async::Task.current.yield
+							body.write("Beep boop") # This will fail.
+						}.to raise_exception(RuntimeError, message: be =~ /big/)
+					end
+
+					it "will stop after finishing" do
+						output_task = reactor.async do
+							body.each do |chunk|
+								expect(chunk).to be == "Hello World!"
+							end
+						end
+
+						body.write("Hello World!")
+						body.close
+
+						expect(body).not.to be(:empty?)
+
+						::Async::Task.current.yield
+
+						expect(output_task).to be(:finished?)
+						expect(body).to be(:empty?)
+					end
+				end
+			end
+		end
+	end
+end

gems.rb

@@ -28,7 +28,7 @@
 	gem "covered"
 	gem "sus"
 	gem "sus-fixtures-async"
-	gem "sus-fixtures-async-http", "~> 0.5"
+	gem "sus-fixtures-async-http", "~> 0.7"
 	gem "sus-fixtures-openssl"
 
 	gem "bake"

test/async/http/body/slowloris.rb

@@ -6,14 +6,14 @@
 require 'async/http/body/slowloris'
 
 require 'sus/fixtures/async'
-require 'sus/fixtures/async/http/body/a_writable_body'
+require 'async/http/body/a_writable_body'
 
 describe Async::HTTP::Body::Slowloris do
 	include Sus::Fixtures::Async::ReactorContext
 
 	let(:body) {subject.new}
 
-	it_behaves_like Sus::Fixtures::Async::HTTP::Body::AWritableBody
+	it_behaves_like Async::HTTP::Body::AWritableBody
 
 	it "closes body with error if throughput is not maintained" do
 		body.write("Hello World")

test/async/http/body/writable.rb

@@ -6,12 +6,12 @@
 require 'async/http/body/slowloris'
 
 require 'sus/fixtures/async'
-require 'sus/fixtures/async/http/body/a_writable_body'
+require 'async/http/body/a_writable_body'
 
 describe Async::HTTP::Body::Writable do
 	include Sus::Fixtures::Async::ReactorContext
 
 	let(:body) {subject.new}
 
-	it_behaves_like Sus::Fixtures::Async::HTTP::Body::AWritableBody
+	it_behaves_like Async::HTTP::Body::AWritableBody
 end