cooper 0.1.1

A simple, in-process, async Actor library for Rust.
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

// cooper-rs/examples/threaded_keyval.rs
//
// This is an example app for the Rust "cooper" library.
//
// Copyright (c) 2021, Frank Pagliughi <fpagliughi@mindspring.com>
// All Rights Reserved
//
// Licensed under the MIT license:
//   <LICENSE or http://opensource.org/licenses/MIT>
// This file may not be copied, modified, or distributed except according
// to those terms.
//

use std::collections::HashMap;
use cooper::ThreadedActor;

/// The internal state type for the Actor
type State = HashMap<String, String>;

/// An actor that can act as a shared key/value store of strings.
#[derive(Clone)]
pub struct SharedMap {
    actor: ThreadedActor<State>,
}

impl SharedMap {
    /// Create a new actor to share a key/value map of string.
    pub fn new() -> Self {
        Self { actor: ThreadedActor::new() }
    }

    /// Insert a value into the shared map.
    pub fn insert<K,V>(&self, key: K, val: V)
    where
        K: Into<String>,
        V: Into<String>,
    {
        let key = key.into();
        let val = val.into();

        self.actor.cast(move |state| {
            state.insert(key, val);
        });
    }


    /// Gets the value, if any, from the shared map that is
    /// associated with the key.
    pub fn get<K: Into<String>>(&self, key: K) -> Option<String> {
        let key = key.into();
        self.actor.call(move |state| {
            state.get(&key).map(|v| v.to_string())
        })
    }
}

// --------------------------------------------------------------------------

fn main() {
    let map = SharedMap::new();

    println!("Inserting entry 'city'...");
    map.insert("city", "Boston");

    println!("Retrieving entry...");
    match map.get("city") {
        Some(s) => println!("Got: {}", s),
        None => println!("Error: No entry found"),
    }
}