resuma 1.1.0

Resuma — resumable SSR Rust web framework: zero hydration, islands, server actions, Flow (Axum).
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

//! Cooperative cancellation — pause aborts in-flight workers (no external broker).

use std::future::Future;

use tokio_util::sync::CancellationToken;

use crate::core::{Result, ResumaError};

/// Create a fresh cancellation scope for one graph execution.
pub fn new_scope() -> CancellationToken {
    CancellationToken::new()
}

/// Run an async block until completion or cancellation.
pub async fn run_cancellable<T, F>(token: &CancellationToken, fut: F) -> Result<T>
where
    F: Future<Output = Result<T>>,
{
    tokio::select! {
        result = fut => result,
        () = token.cancelled() => Err(ResumaError::Cancelled),
    }
}

/// Returns `Err(Cancelled)` when the scope has been signalled (e.g. pause).
pub fn check(token: &CancellationToken) -> Result<()> {
    if token.is_cancelled() {
        Err(ResumaError::Cancelled)
    } else {
        Ok(())
    }
}