summaryrefslogtreecommitdiff
path: root/ext/kv/remote.rs
diff options
context:
space:
mode:
author林炳权 <695601626@qq.com>2023-08-27 12:04:12 +0800
committerGitHub <noreply@github.com>2023-08-26 22:04:12 -0600
commit2080669943e79aba619bc80829172c696ec1f15c (patch)
tree9eb317754a9632220abb3df238a30375164d705a /ext/kv/remote.rs
parente4cebf3e0da539321727b0f0e43ddce5679635b1 (diff)
chore: update to Rust 1.72 (#20258)
<!-- Before submitting a PR, please read https://deno.com/manual/contributing 1. Give the PR a descriptive title. Examples of good title: - fix(std/http): Fix race condition in server - docs(console): Update docstrings - feat(doc): Handle nested reexports Examples of bad title: - fix #7123 - update docs - fix bugs 2. Ensure there is a related issue and it is referenced in the PR text. 3. Ensure there are tests that cover the changes. 4. Ensure `cargo test` passes. 5. Ensure `./tools/format.js` passes without changing files. 6. Ensure `./tools/lint.js` passes. 7. Open as a draft PR if your work is still in progress. The CI won't run all steps, but you can add '[ci]' to a commit message to force it to. 8. If you would like to run the benchmarks on the CI, add the 'ci-bench' label. --> As the title. --------- Co-authored-by: Matt Mastracci <matthew@mastracci.com>
Diffstat (limited to 'ext/kv/remote.rs')
-rw-r--r--ext/kv/remote.rs12
1 files changed, 9 insertions, 3 deletions
diff --git a/ext/kv/remote.rs b/ext/kv/remote.rs
index 448a87b0d..21286fd47 100644
--- a/ext/kv/remote.rs
+++ b/ext/kv/remote.rs
@@ -494,9 +494,15 @@ async fn call_remote<
// `unwrap()` never fails because `tx` is owned by the task held by `refresher`.
metadata_rx.changed().await.unwrap();
};
- let Some(sc_endpoint) = metadata.endpoints.iter().find(|x| x.consistency == "strong") else {
- return Err(type_error("No strong consistency endpoint is available for this database"));
- };
+ let Some(sc_endpoint) = metadata
+ .endpoints
+ .iter()
+ .find(|x| x.consistency == "strong")
+ else {
+ return Err(type_error(
+ "No strong consistency endpoint is available for this database",
+ ));
+ };
let full_url = format!("{}/{}", sc_endpoint.url, method);
{