harmos-runtime 0.1.8

Harmos runtime: managed state, undo, recovery, background work and typed streams.
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

/* ***
 *
 * Harmos
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * ***
 */

/* === Modules === */

/* === Re-Exports === */

pub use harmos_sdk::operations::streaming::{StreamInput, StreamItem, StreamSettings};

/* === Imports === */

// Standard Library Imports
use std::sync::Arc;
// Third Party Imports
// Local Imports
use crate::{Error, Result};
use harmos_sdk::operations::streaming as portable;

/* === Constants === */

/* === Macros === */

/* === Type Aliases === */

pub type StreamOutput<T> = portable::StreamOutput<T>;
pub type StreamPermit<'a, T> = portable::StreamPermit<'a, T>;
/* === Structs === */

/* === Enums === */

/* === Traits === */

/* === Implementations === */

impl From<portable::Error> for Error {
    fn from(error: portable::Error) -> Self {
        match error {
            portable::Error::Settings => Self::InvalidInput {
                field: "operation stream limits",
                reason: "capacity exceeds the semaphore claim limit",
            },
            portable::Error::Capacity => Self::ResourceExhausted { resource: "operation stream bytes" },
            portable::Error::Construction => Self::InvalidInput {
                field: "operation stream construction bound",
                reason: "constructed value exceeds its reserved bytes",
            },
            portable::Error::Closed => Self::NotReady { domain: "operation stream input" },
            portable::Error::Ownership => Self::InvalidInput {
                field: "operation stream payload",
                reason: "original owned payload cannot be moved into a request",
            },
            portable::Error::Codec(source) => Self::TaskFailed {
                domain: "operation stream decode",
                source: Arc::new(source),
            },
        }
    }
}
/* === Public Functions === */

pub fn stream<T>(settings: StreamSettings) -> Result<(StreamOutput<T>, StreamInput<T>)> {
    portable::channel(settings).map_err(Into::into)
}
/* === Private Functions === */

/* === Tests === */