alkdev/alknet
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

review(call): fix fmt drift in adapter.rs and env.rs (call/review-call-sync)

Browse Source
This commit is contained in:
glm-5.2
2026-06-28 22:28:50 +00:00
parent 1af81346d1
commit 8bbc84ca72
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
crates/alknet-call/src/protocol/adapter.rs
View File

@@ -559,7 +559,8 @@ mod tests {
.set_identity(peer_identity) .set_identity(peer_identity)
.expect("identity not yet set"); .expect("identity not yet set");
let context = adapter.build_root_context("req-5".to_string(), "fs/readFile", None, None, &conn); let context =
adapter.build_root_context("req-5".to_string(), "fs/readFile", None, None, &conn);
let scoped = ScopedOperationEnv::new(["worker/exec"]); let scoped = ScopedOperationEnv::new(["worker/exec"]);
let invoke_ctx = OperationContext { let invoke_ctx = OperationContext {
@@ -616,7 +617,8 @@ mod tests {
); );
conn.register_imported(imported); conn.register_imported(imported);
let context = adapter.build_root_context("req-6".to_string(), "fs/readFile", None, None, &conn); let context =
adapter.build_root_context("req-6".to_string(), "fs/readFile", None, None, &conn);
let scoped = ScopedOperationEnv::new(["worker/exec"]); let scoped = ScopedOperationEnv::new(["worker/exec"]);
let invoke_ctx = OperationContext { let invoke_ctx = OperationContext {

4
crates/alknet-call/src/registry/env.rs
View File

@@ -283,9 +283,7 @@ impl OperationEnv for PeerCompositeEnv {
} }
fn peer_contains(&self, peer: &PeerId, name: &str) -> bool { fn peer_contains(&self, peer: &PeerId, name: &str) -> bool {
self.connections self.connections.get(peer).is_some_and(|c| c.contains(name))
.get(peer)
.is_some_and(|c| c.contains(name))
} }
fn peer_ids(&self) -> Vec<PeerId> { fn peer_ids(&self) -> Vec<PeerId> {