fix exit condition

This commit is contained in:
Conrad Ludgate
2024-02-14 15:56:50 +00:00
parent c994c80962
commit 0d74bc0492

View File

@@ -61,6 +61,10 @@ impl RedisPublisherClient {
.xread_options(&["neon:endpoints:testing"], &[&id], &opts)
.await
.unwrap();
if res.keys.is_empty() {
break;
}
assert_eq!(res.keys.len(), 1);
let res = res.keys.pop().unwrap();
assert_eq!(res.key, "neon:endpoints:testing");