Skip to content

Commit 2d4ffc7

Browse files
committed
shorten with some 'let else'
1 parent 38205c8 commit 2d4ffc7

File tree

1 file changed

+17
-22
lines changed

1 file changed

+17
-22
lines changed

capnp-rpc/src/rpc.rs

Lines changed: 17 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -585,12 +585,10 @@ impl<VatId> ConnectionState<VatId> {
585585
}
586586
}
587587
});
588-
match self.disconnect_fulfiller.borrow_mut().take() {
589-
None => unreachable!(),
590-
Some(fulfiller) => {
591-
let _ = fulfiller.send(Promise::from_future(promise.attach(c)));
592-
}
593-
}
588+
let Some(fulfiller) = self.disconnect_fulfiller.borrow_mut().take() else {
589+
unreachable!()
590+
};
591+
let _ = fulfiller.send(Promise::from_future(promise.attach(c)));
594592
}
595593

596594
// Transform a future into a promise that gets executed even if it is never polled.
@@ -1051,18 +1049,16 @@ impl<VatId> ConnectionState<VatId> {
10511049

10521050
{
10531051
let slots = &mut connection_state.answers.borrow_mut().slots;
1054-
match slots.get_mut(&question_id) {
1055-
Some(answer) => {
1056-
answer.pipeline = Some(Box::new(pipeline));
1057-
if redirect_results {
1058-
answer.redirected_results = redirected_results_done_promise;
1059-
// More to do here?
1060-
} else {
1061-
answer.call_completion_promise =
1062-
Some(connection_state.eagerly_evaluate(fork));
1063-
}
1064-
}
1065-
None => unreachable!(),
1052+
let Some(answer) = slots.get_mut(&question_id) else {
1053+
unreachable!()
1054+
};
1055+
answer.pipeline = Some(Box::new(pipeline));
1056+
if redirect_results {
1057+
answer.redirected_results = redirected_results_done_promise;
1058+
// More to do here?
1059+
} else {
1060+
answer.call_completion_promise =
1061+
Some(connection_state.eagerly_evaluate(fork));
10661062
}
10671063
}
10681064
}
@@ -1432,11 +1428,10 @@ impl<VatId> ConnectionState<VatId> {
14321428
inner = resolved;
14331429
}
14341430
if inner.get_brand() == state.get_brand() {
1435-
let result = match Client::from_ptr(inner.get_ptr(), state) {
1436-
Some(c) => c.write_descriptor(descriptor),
1437-
None => unreachable!(),
1431+
let Some(c) = Client::from_ptr(inner.get_ptr(), state) else {
1432+
unreachable!()
14381433
};
1439-
Ok(result)
1434+
Ok(c.write_descriptor(descriptor))
14401435
} else {
14411436
let ptr = inner.get_ptr();
14421437
let contains_key = state.exports_by_cap.borrow().contains_key(&ptr);

0 commit comments

Comments
 (0)