resuma 0.4.7

Resuma — resumable SSR Rust web framework: zero hydration, islands, server actions, Flow (Axum).
Documentation 
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

//! Optional deferred streaming hook installed by `resuma-flow`.

use std::pin::Pin;

use crate::core::view::View;
use crate::ssr::{PageOptions, StreamChunk};
use futures_util::Stream;

type DeferredStreamHook =
    fn(View, &PageOptions, &str) -> Option<Pin<Box<dyn Stream<Item = StreamChunk> + Send>>>;

static HOOK: parking_lot::RwLock<Option<DeferredStreamHook>> = parking_lot::RwLock::new(None);

/// Register renderer for deferred loader streaming (called from `resuma-flow` ctor).
pub fn set_deferred_stream_hook(hook: DeferredStreamHook) {
    *HOOK.write() = Some(hook);
}

/// When a deferred stream plan was staged, return the chunked response stream.
pub fn try_deferred_stream(
    shell: View,
    opts: &PageOptions,
    path: &str,
) -> Option<Pin<Box<dyn Stream<Item = StreamChunk> + Send>>> {
    (*HOOK.read())?(shell, opts, path)
}