Handling of ctrl+c with save is unclear about yaque HOT 6 CLOSED

match receiver {
        Ok(receiver) => {
            let receiver = Arc::new(Mutex::new(receiver));
            let receiver_clone = Arc::clone(&receiver);

            tokio::spawn(async move {
                tokio::signal::ctrl_c()
                    .await
                    .expect("failed to listen for ctrl-c event");
                info!("Received ctr-c. Cleaning up");
                receiver_clone
                    .lock()
                    .await
                    .save()
                    .expect("Unable to save queue");
                exit(0);
            });

            loop {
                let mut receiver_lock = receiver.lock().await;
                let data = receiver_lock.recv().await;

                match data {
                    Ok(data) => {
                        let email_bytes = &*data;
                        let email_json = serde_json::from_slice::<EmailPayload>(email_bytes)?;

                        if let Err(e) = send_email_job(&email_json).await {
                            tracing::error!(
                                "Error while sending email: {:?}. Adding it to the queue again",
                                e
                            );
                            // FIXME: This can race the lock leading to an error. We should
                            //        probably handle this better.
                            let mut sender = Sender::open(config.task_folder.clone())?;
                            let json_bytes = serde_json::to_vec(&email_json)?;
                            sender.send(json_bytes).await?;
                        }
                        // Mark the job as complete
                        data.commit()?;
                    }
                    Err(e) => {
                        tracing::error!("Error while receiving data from receiver: {:?}", e);
                    }
                }
            }
        }
        Err(e) => {
            error!("Unable to open receiver: {:?}. Giving up.", e);
            Ok(())
        }
    }