DEV Community

Grayson Hay
Grayson Hay

Posted on • Originally published at garden.graysonarts.com

2

Rust Snippet: Exec with Update Intervals

Recently, I needed to kick off a long running process for encoding videos using ffmpeg in the middle of handling an SQS message. In order to keep the message from showing back up in the queue before the video processing is finished.

So that means, I need to be able to send the change message visibility timeout periodically during the process. so, I came up with this little function to help. It calls a “progress” function every 10 seconds while the command is executing, and then ends once it’s done.

Using tokio as the Async Runtime

pub async fn exec<F, Fut>(mut cmd: Command, progress: F) -> Result<Output, ProgressingExecError>
where
    F: Fn() -> Fut,
    Fut: Future<Output = ()>,
{
    let (tx, mut rx) = oneshot::channel();
    let mut interval = interval(Duration::from_millis(10000));

    tokio::spawn(async move {
        let output = cmd.output().await;
        let _ = tx.send(output);
    });

    loop {
        tokio::select! {
            _ = interval.tick() => progress().await,
            msg = &mut rx => return Ok(msg??)
        }
    }
}
Enter fullscreen mode Exit fullscreen mode

Top comments (0)

Billboard image

The Next Generation Developer Platform

Coherence is the first Platform-as-a-Service you can control. Unlike "black-box" platforms that are opinionated about the infra you can deploy, Coherence is powered by CNC, the open-source IaC framework, which offers limitless customization.

Learn more

👋 Kindness is contagious

Please leave a ❤️ or a friendly comment on this post if you found it helpful!

Okay