decdn-cache 0.1.0

Cache engine wrapping iroh-blobs with origin pull-through for deCDN
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

use super::OriginFetch;

/// The bytes-less variants collect to `None`. `AlreadyAdmitted` carries no
/// stream (the origin already streamed the blob into the store), so a
/// caller draining it gets `None` just as it does for `NotFound` — never a
/// panic or an empty buffer masquerading as content. The pull-through path
/// never drains it (it short-circuits on the variant), so this only pins the
/// contract for the `collect_to_bytes` helper's other callers.
#[tokio::test]
async fn bytesless_variants_collect_to_none() {
    assert!(
        OriginFetch::AlreadyAdmitted
            .collect_to_bytes()
            .await
            .unwrap()
            .is_none()
    );
    assert!(
        OriginFetch::NotFound
            .collect_to_bytes()
            .await
            .unwrap()
            .is_none()
    );
}