Add size (running children) to controller ready! notification.

Author: ioquatix

lib/async/container/controller.rb

@@ -149,7 +149,7 @@ def restart
 					old_container&.stop(@graceful_stop)
 				end
 
-				@notify&.ready!
+				@notify&.ready!(size: @container.size)
 			ensure
 				# If we are leaving this function with an exception, try to kill the container:
 				container&.stop(false)
@@ -185,7 +185,7 @@ def reload
 
 			# Enter the controller run loop, trapping `SIGINT` and `SIGTERM`.
 			def run
-				@notify&.status!("Initializing...")
+				@notify&.status!("Initializing controller...")
 
 				with_signal_handlers do
 					self.start

lib/async/container/generic.rb

@@ -51,6 +51,11 @@ def initialize(**options)
 			# @attribute [Group] The group of running children instances.
 			attr :group
 
+			# @returns [Integer] The number of running children instances.
+			def size
+				@group.size
+			end
+			
 			# @attribute [Hash(Child, Hash)] The state of each child instance.
 			attr :state
 

lib/async/container/group.rb

@@ -32,6 +32,11 @@ def inspect
 			# @attribute [Hash(IO, Fiber)] the running tasks, indexed by IO.
 			attr :running
 
+			# @returns [Integer] The number of running processes.
+			def size
+				@running.size
+			end
+			
 			# Whether the group contains any running processes.
 			# @returns [Boolean]
 			def running?

test/async/container/notify/log.rb

@@ -18,6 +18,9 @@
 
 		lines = File.readlines(notify_log).map{|line| JSON.parse(line)}
 
-		expect(lines.last).to be == {"ready" => true}
+		expect(lines.last).to have_keys(
+			"ready" => be == true,
+			"size" => be > 0,
+		)
 	end
 end

test/async/container/notify/pipe.rb

@@ -24,7 +24,7 @@
 		container.sleep
 
 		_child, state = container.state.first
-		expect(state).to be == {status: "Initializing..."}
+		expect(state).to be == {status: "Initializing controller..."}
 
 		container.wait