Fix test.

Author: ioquatix

fixtures/async/container/supervisor/a_server.rb

@@ -12,6 +12,25 @@
 module Async
 	module Container
 		module Supervisor
+			class RegistrationMonitor
+				def initialize
+					@registrations = []
+				end
+				
+				attr :registrations
+				
+				def run
+				end
+				
+				def register(connection)
+					@registrations << connection
+				end
+				
+				def remove(connection)
+					@registrations.delete(connection)
+				end
+			end
+			
 			AServer = Sus::Shared("a server") do
 				include Sus::Fixtures::Async::SchedulerContext
 
@@ -25,7 +44,9 @@ def around(&block)
 					end
 				end
 
-				let(:server) {Async::Container::Supervisor::Server.new(@bound_endpoint)}
+				let(:registration_monitor) {RegistrationMonitor.new}
+				let(:monitors) {[registration_monitor]}
+				let(:server) {Async::Container::Supervisor::Server.new(@bound_endpoint, monitors: monitors)}
 
 				before do
 					@bound_endpoint = endpoint.bound

lib/async/container/supervisor/server.rb

@@ -69,7 +69,6 @@ def run
 
 						task.children&.each(&:wait)
 					ensure
-						Console.info(self, "Stopping...")
 						task.stop
 					end
 				end

lib/async/container/supervisor/service.rb

@@ -4,6 +4,7 @@
 # Copyright, 2025, by Samuel Williams.
 
 require "async"
+require "async/service/generic"
 require "io/endpoint/bound_endpoint"
 
 module Async

test/async/container/supervisor.rb

@@ -23,12 +23,11 @@ def to_json(...)
 		client = Async::Container::Supervisor::Client.new(instance, endpoint)
 		connection = client.connect
 
-		sleep(0.001) until server.registered.any?
+		sleep(0.001) until registration_monitor.registrations.any?
 
-		registration = server.registered.first
-		expect(registration.last).to have_keys(
-			action: be == "register",
-			instance: be == instance.as_json,
+		registration = registration_monitor.registrations.first
+		expect(registration.state).to have_keys(
+			process_id: be == ::Process.pid
 		)
 	end
 end