class Async::Container::Group
def initialize(health_check_interval: 1.0)
Initialize an empty group.
def initialize(health_check_interval: 1.0) @health_check_interval = health_check_interval # The running fibers, indexed by IO: @running = {} # This queue allows us to wait for processes to complete, without spawning new processes as a result. @queue = nil end