Skip to content

Commit 777477f

Browse files
committed
Remove borked #remove method.
1 parent 86de411 commit 777477f

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

lib/async/container/supervisor/memory_monitor.rb

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -31,13 +31,6 @@ def add(process_id)
3131
@cluster.add(process_id, **@options)
3232
end
3333

34-
# Remove a process from the memory monitor.
35-
#
36-
# @parameter process_id [Integer] The process ID to remove.
37-
def remove(process_id)
38-
@cluster.remove(process_id)
39-
end
40-
4134
# Register the connection (worker) with the memory monitor.
4235
def register(connection)
4336
Console.info(self, "Registering connection:", connection: connection, state: connection.state)
@@ -62,7 +55,7 @@ def remove(connection)
6255

6356
if connections.empty?
6457
Console.info(self, "Removing process:", process_id: process_id)
65-
self.remove(process_id)
58+
@cluster.remove(process_id)
6659
end
6760
end
6861
end

0 commit comments

Comments
 (0)