kash 0.7.1

Function and method cache and memoization
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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

#![allow(
    clippy::arithmetic_side_effects,
    clippy::trivially_copy_pass_by_ref,
    clippy::needless_pass_by_value,
    clippy::unwrap_used
)]
use kash::kash;
use std::thread::sleep;
use std::time::{Duration, Instant};

struct Example;

impl Example {
    #[kash(size = "50", in_impl)]
    pub async fn slow_fn(n: u32) -> String {
        if n == 0 {
            return "done".to_string();
        }
        sleep(Duration::new(1, 0));
        Box::pin(Example::slow_fn(n - 1)).await
    }

    #[kash(size = "50", in_impl)]
    pub async fn slow_fn_with_ref_mut_self(&mut self, n: u32) -> String {
        if n == 0 {
            return "done".to_string();
        }
        sleep(Duration::new(1, 0));
        Box::pin(self.slow_fn_with_ref_mut_self(n - 1)).await
    }

    #[kash(size = "50", in_impl)]
    pub async fn slow_fn_with_self(self, n: u32) -> String {
        if n == 0 {
            return "done".to_string();
        }
        sleep(Duration::new(1, 0));
        Box::pin(self.slow_fn_with_self(n - 1)).await
    }

    #[kash(size = "50", in_impl)]
    pub async fn slow_fn_with_ref_self(&self, n: u32) -> String {
        if n == 0 {
            return "done".to_string();
        }
        sleep(Duration::new(1, 0));
        Box::pin(self.slow_fn_with_ref_self(n - 1)).await
    }

    #[allow(unused_mut)]
    #[kash(size = "50", in_impl)]
    pub async fn slow_fn_with_mut_self(mut self, n: u32) -> String {
        if n == 0 {
            return "done".to_string();
        }
        sleep(Duration::new(1, 0));
        Box::pin(self.slow_fn_with_mut_self(n - 1)).await
    }

    #[allow(clippy::needless_lifetimes)]
    #[kash(size = "50", in_impl)]
    pub async fn slow_fn_with_lifetime<'a>(&self, n: &'a i32) -> String {
        if *n == 0 {
            return "done".to_string();
        }
        sleep(Duration::new(1, 0));
        Box::pin(self.slow_fn_with_lifetime(&(n - 1))).await
    }
}

#[tokio::main]
pub async fn main() {
    println!("[kash] Initial run...");
    let now = Instant::now();
    Example::slow_fn(10).await;
    println!("[kash] Elapsed: {}\n", now.elapsed().as_secs());

    println!("[kash] Cached run...");
    let now = Instant::now();
    Example::slow_fn(10).await;
    println!("[kash] Elapsed: {}\n", now.elapsed().as_secs());

    println!("[kash] Cached run...");
    let now = Instant::now();
    let example = Example;
    example.slow_fn_with_self(10).await;
    println!("[kash] Elapsed: {}\n", now.elapsed().as_secs());

    // Inspect the cache
    {
        // println!("[kash] ** Cache info **");
        // let cache = Example::slow_fn_get_cache_ident().clone();
        // assert_eq!(cache.cache_hits().unwrap(), 1);
        // println!("[kash] hits=1 -> {:?}", cache.cache_hits().unwrap() == 1);
        // assert_eq!(cache.cache_misses().unwrap(), 11);
        // println!(
        //     "[kash] misses=11 -> {:?}",
        //     cache.cache_misses().unwrap() == 11
        // );
        // make sure the cache-lock is dropped
    }

    println!("done!");
}