Skip to content

Commit ee75cc0

Browse files
committed
refactor: remove one level of indentation
Using `let Some() else {}` instead of `if let Some() {}`
1 parent d0eed8d commit ee75cc0

File tree

1 file changed

+36
-37
lines changed

1 file changed

+36
-37
lines changed

src/state_actor.rs

Lines changed: 36 additions & 37 deletions
Original file line numberDiff line numberDiff line change
@@ -482,47 +482,46 @@ pub async fn gitlab_tokens_actor(
482482

483483
// We now wait for some messages
484484
loop {
485-
let msg = receiver.recv().await;
486-
if let Some(msg_value) = msg {
487-
match msg_value {
488-
Message::Get { respond_to } => {
489-
debug!("received Message::Get");
490-
respond_to.send(state.clone()).unwrap_or_else(|_| {
491-
warn!("Failed to send reponse : oneshot channel was closed");
492-
});
493-
}
494-
Message::Update => {
495-
// We are going to spawn a async task to get the data from gitlab.
496-
// This task will send us Message::Set with the result to
497-
// update our 'state' variable
498-
debug!("received Message::Update");
499-
tokio::spawn(get_gitlab_data(
500-
gitlab_connection.clone(),
501-
owned_entities_only,
502-
sender.clone(),
503-
max_concurrent_requests,
504-
skip_users_tokens,
505-
skip_non_expiring_tokens,
506-
));
507-
}
508-
Message::Set(gitlab_data) => {
509-
debug!("received Message::Set");
510-
match gitlab_data {
511-
Ok(data) => {
512-
if data.is_empty() {
513-
warn!("No token has been found");
514-
state = ActorState::NoToken;
515-
} else {
516-
state = ActorState::Loaded(data);
517-
}
485+
let Some(msg) = receiver.recv().await else {
486+
error!("recv failed");
487+
break;
488+
};
489+
490+
match msg {
491+
Message::Get { respond_to } => {
492+
debug!("received Message::Get");
493+
respond_to.send(state.clone()).unwrap_or_else(|_| {
494+
warn!("Failed to send reponse : oneshot channel was closed");
495+
});
496+
}
497+
Message::Update => {
498+
// We are going to spawn a async task to get the data from gitlab.
499+
// This task will send us Message::Set with the result to
500+
// update our 'state' variable
501+
debug!("received Message::Update");
502+
tokio::spawn(get_gitlab_data(
503+
gitlab_connection.clone(),
504+
owned_entities_only,
505+
sender.clone(),
506+
max_concurrent_requests,
507+
skip_users_tokens,
508+
skip_non_expiring_tokens,
509+
));
510+
}
511+
Message::Set(gitlab_data) => {
512+
debug!("received Message::Set");
513+
match gitlab_data {
514+
Ok(data) => {
515+
if data.is_empty() {
516+
warn!("No token has been found");
517+
state = ActorState::NoToken;
518+
} else {
519+
state = ActorState::Loaded(data);
518520
}
519-
Err(err) => state = ActorState::Error(err),
520521
}
522+
Err(err) => state = ActorState::Error(err),
521523
}
522524
}
523-
} else {
524-
error!("recv failed");
525-
break;
526525
}
527526
}
528527
}

0 commit comments

Comments
 (0)