We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ba36b97 commit b6fcd29Copy full SHA for b6fcd29
async-nats/tests/kv_tests.rs
@@ -927,7 +927,17 @@ mod kv {
927
let local_kv = leaf_js.get_key_value("MIRROR").await.unwrap();
928
929
local_kv.put("name", "rip".into()).await.unwrap();
930
-
+ tryhard::retry_fn(|| async {
931
+ match local_kv.get("name").await {
932
+ Ok(Some(name)) => {
933
+ assert_eq!(from_utf8(&name).unwrap(), "rip");
934
+ Ok::<(), async_nats::Error>(())
935
+ }
936
+ _ => Err("key not found".into()),
937
938
+ })
939
+ .retries(5)
940
+ .exponential_backoff(Duration::from_millis(100));
941
let name = local_kv.get("name").await.unwrap();
942
assert_eq!(from_utf8(&name.unwrap()).unwrap(), "rip");
943
0 commit comments