harmos-runtime 0.1.3

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

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

/* === Modules === */

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

pub(super) use harmos_sdk::operations::streaming::RequestClaims;
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, Error>;
pub type StreamPermit<'a, T> = portable::StreamPermit<'a, T, Error>;
/* === 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)
}
/* === Private Functions === */

/* === Tests === */