Modernize code.

Author: ioquatix

.github/workflows/documentation-coverage.yaml

@@ -7,6 +7,7 @@ permissions:
 
 env:
   COVERAGE: PartialSummary
+  BUNDLE_WITH: maintenance
 
 jobs:
   validate:

gems.rb

@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2017-2025, by Samuel Williams.
+# Copyright, 2017-2026, by Samuel Williams.
 
 source "https://rubygems.org"
 
@@ -14,13 +14,14 @@
 
 	gem "agent-context"
 
+	gem "decode"
+	
 	gem "utopia-project"
 end
 
 group :test do
 	gem "sus"
 	gem "covered"
-	gem "decode"
 
 	gem "rubocop"
 	gem "rubocop-socketry"

readme.md

@@ -82,6 +82,22 @@ We welcome contributions to this project.
 4.  Push to the branch (`git push origin my-new-feature`).
 5.  Create new Pull Request.
 
+### Running Tests
+
+To run the test suite:
+
+``` shell
+bundle exec sus
+```
+
+### Making Releases
+
+To make a new release:
+
+``` shell
+bundle exec bake gem:release:patch # or minor or major
+```
+
 ### Developer Certificate of Origin
 
 In order to protect users of this project, we require all contributors to comply with the [Developer Certificate of Origin](https://developercertificate.org/). This ensures that all contributions are properly licensed and attributed.

test/async/container/forked.rb

@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2018-2025, by Samuel Williams.
+# Copyright, 2018-2026, by Samuel Williams.
 # Copyright, 2020, by Olle Jonsson.
 
 require "async/container/best"
@@ -10,61 +10,61 @@
 
 describe Async::Container::Forked do
 	let(:container) {subject.new}
-		
+	
 	it_behaves_like Async::Container::AContainer
-		
+	
 	it "can restart child" do
 		trigger = IO.pipe
 		pids = IO.pipe
-			
+		
 		thread = Thread.new do
 			container.async(restart: true) do
 				trigger.first.gets
 				pids.last.puts Process.pid.to_s
 			end
-				
+			
 			container.wait
 		end
-			
+		
 		3.times do
 			trigger.last.puts "die"
 			_child_pid = pids.first.gets
 		end
-			
+		
 		thread.kill
 		thread.join
-			
+		
 		expect(container.statistics.spawns).to be == 1
 		expect(container.statistics.restarts).to be == 2
 	end
-		
+	
 	it "can handle interrupts" do
 		finished = IO.pipe
 		interrupted = IO.pipe
-			
+		
 		container.spawn(restart: true) do |instance|
 			Thread.handle_interrupt(Interrupt => :never) do
 				instance.ready!
-					
+				
 				finished.first.gets
 			rescue ::Interrupt
 				interrupted.last.puts "incorrectly interrupted"
 			end
 		rescue ::Interrupt
 			interrupted.last.puts "correctly interrupted"
 		end
-			
+		
 		container.wait_until_ready
-			
+		
 		container.group.interrupt
 		sleep(0.001)
 		finished.last.puts "finished"
-			
+		
 		expect(interrupted.first.gets).to be == "correctly interrupted\n"
-			
+		
 		container.stop
 	end
-		
+	
 	it "should be multiprocess" do
 		expect(subject).to be(:multiprocess?)
 	end

test/async/container/hybrid.rb

@@ -1,15 +1,15 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2019-2025, by Samuel Williams.
+# Copyright, 2019-2026, by Samuel Williams.
 
 require "async/container/hybrid"
 require "async/container/best"
 require "async/container/a_container"
 
 describe Async::Container::Hybrid do
 	it_behaves_like Async::Container::AContainer
-		
+	
 	it "should be multiprocess" do
 		expect(subject).to be(:multiprocess?)
 	end

test/async/container/notify.rb

@@ -12,36 +12,36 @@
 	let(:server) {subject::Server.open}
 	let(:notify_socket) {server.path}
 	let(:client) {subject::Socket.new(notify_socket)}
-		
+	
 	it "can send and receive messages" do
 		context = server.bind
-			
+		
 		client.send(hello: "world", count: 42)
-			
+		
 		message = context.receive
-			
+		
 		# Custom fields are transmitted as strings per the systemd protocol
 		expect(message).to be == {hello: "world", count: "42"}
 	end
-		
+	
 	with "#ready!" do
 		it "should send message" do
 			begin
 				context = server.bind
-					
+				
 				pid = fork do
 					client.ready!
 				end
-					
+				
 				messages = []
-					
+				
 				Sync do
 					context.receive do |message, address|
 						messages << message
 						break
 					end
 				end
-					
+				
 				expect(messages.last).to have_keys(
 					ready: be == true
 				)
@@ -51,77 +51,77 @@
 			end
 		end
 	end
-		
+	
 	with "#healthy!" do
 		it "sends healthy message" do
 			context = server.bind
-				
+			
 			client.healthy!
-				
+			
 			message = context.receive
-				
+			
 			expect(message).to have_keys(
 				healthy: be == true
 			)
 		end
-			
+		
 		it "sends healthy message with additional details" do
 			context = server.bind
-				
+			
 			client.healthy!(status: "All systems operational", uptime: 3600)
-				
+			
 			message = context.receive
-				
+			
 			expect(message).to have_keys(
 				healthy: be == true,
 				status: be == "All systems operational",
 				uptime: be == "3600"
 			)
 		end
 	end
-		
+	
 	with "#send" do
 		it "sends message" do
 			context = server.bind
-				
+			
 			client.send(hello: "world")
-				
+			
 			message = context.receive
-				
+			
 			expect(message).to be == {hello: "world"}
 		end
-			
+		
 		it "fails if the message is too big" do
 			context = server.bind
-				
+			
 			expect do
 				client.send(test: "x" * (subject::Socket::MAXIMUM_MESSAGE_SIZE+1))
 			end.to raise_exception(ArgumentError, message: be =~ /Message length \d+ exceeds \d+/)
 		end
 	end
-		
+	
 	with "#stopping!" do
 		it "sends stopping message" do
 			context = server.bind
-				
+			
 			client.stopping!
-				
+			
 			message = context.receive
-				
+			
 			expect(message).to have_keys(
 				stopping: be == true
 			)
 		end
 	end
-		
+	
 	with "#error!" do
 		it "sends error message" do
 			context = server.bind
-				
+			
 			client.error!("Boom!")
-				
+			
 			message = context.receive
-				
+			
 			expect(message).to have_keys(
 				status: be == "Boom!",
 				errno: be == -1,