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 20e0524 commit 32a0516Copy full SHA for 32a0516
rclrs/src/subscription.rs
@@ -272,9 +272,7 @@ where
272
}
273
274
fn execute(&self) -> Result<(), RclrsError> {
275
- // Immediately evaluated closure, to handle SubscriptionTakeFailed
276
- // outside this match
277
- match (|| {
+ let evaluate = || {
278
match &mut *self.callback.lock().unwrap() {
279
AnySubscriptionCallback::Regular(cb) => {
280
let (msg, _) = self.take()?;
@@ -302,7 +300,11 @@ where
302
300
303
301
304
Ok(())
305
- })() {
+ };
+
+ // Immediately evaluated closure, to handle SubscriptionTakeFailed
306
+ // outside this match
307
+ match evaluate() {
308
Err(RclrsError::RclError {
309
code: RclReturnCode::SubscriptionTakeFailed,
310
..
0 commit comments