Skip to content

Commit

Permalink
Fix issues with nested Sets (#233)
Browse files Browse the repository at this point in the history
  • Loading branch information
petergebala authored Oct 11, 2024
1 parent 19abaac commit 8c0262a
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ def fresh_cluster_composition_fetched(composition_lookup_result)
addresses_to_retain = @routing_table_registry.all_servers.map(&:unicast_stream).reduce(&:+)

composition_lookup_result.resolved_initial_routers&.then do |addresses|
addresses_to_retain << addresses
addresses_to_retain.merge(addresses)
end

@connection_pool.retain_all(addresses_to_retain)
Expand Down

0 comments on commit 8c0262a

Please sign in to comment.