diff --git a/tests/test_stream_service.c b/tests/test_stream_service.c
index aa9f69909..9ed93c109 100644
--- a/tests/test_stream_service.c
+++ b/tests/test_stream_service.c
@@ -2037,8 +2037,9 @@ static void test_member_lifecycle(void) {
     CHECK(member_owner_update(1, 1, 1001, 0, 0) >= 0);
     CHECK(!stream_handle_active(reader));
     uint64_t ready_deadline = get_time_tb() + 100000;
-    while (!stream_member_online(nodes[1], GROUP1, nodes[0]->node_id) && get_time_tb() < ready_deadline) test_clock_poll(ua, 100);
-    CHECK(stream_member_online(nodes[1], GROUP1, nodes[0]->node_id));
+    struct TOPO_GROUP* restored_group = topo_groups_find(nodes[1]->topo_groups, GROUP1);
+    while (!topo_group_peer_ready(restored_group, nodes[0]->node_id) && get_time_tb() < ready_deadline) test_clock_poll(ua, 100);
+    CHECK(topo_group_peer_ready(restored_group, nodes[0]->node_id));
     stream_close(reader); reader = NULL;
     CHECK(stream_subscribe_manual_open(nodes[1], GROUP1, nodes[0]->node_id, &reader) == STREAM_OK);
     DEBUG_INFO(DEBUG_CATEGORY_STREAM, "[PASS] own removal: channel closes/new open denied, other channel writes, "