wireframe 0.3.0

Simplify building servers and clients for custom binary protocols.
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

//! Step definitions for derived memory budget default scenarios.

use rstest_bdd_macros::{given, then, when};

use crate::fixtures::derived_memory_budgets::{
    DerivedMemoryBudgetsWorld,
    ExplicitBudgetConfig,
    TestResult,
};

#[given("a derived-budget app with buffer capacity {capacity:u64}")]
fn given_derived_budget_app(
    derived_memory_budgets_world: &mut DerivedMemoryBudgetsWorld,
    capacity: u64,
) -> TestResult {
    let capacity = usize::try_from(capacity)?;
    derived_memory_budgets_world.start_app_derived(capacity)
}

#[given("a derived-budget app with buffer capacity {capacity:u64} and explicit budgets {config}")]
fn given_derived_budget_app_explicit(
    derived_memory_budgets_world: &mut DerivedMemoryBudgetsWorld,
    capacity: u64,
    config: ExplicitBudgetConfig,
) -> TestResult {
    let capacity = usize::try_from(capacity)?;
    derived_memory_budgets_world.start_app_explicit(capacity, config)
}

#[when(
    "derived-budget first frames for keys {start:u64} to {end:u64} each with body {body:string} \
     arrive"
)]
fn when_derived_budget_first_frames_for_range(
    derived_memory_budgets_world: &mut DerivedMemoryBudgetsWorld,
    start: u64,
    end: u64,
    body: String,
) -> TestResult {
    derived_memory_budgets_world.send_first_frames_for_range(start, end, &body)
}

#[when(
    "derived-budget first frames for keys {start:u64} to {end:u64} each with body size {size:u64} \
     arrive"
)]
fn when_derived_budget_first_frames_for_range_sized(
    derived_memory_budgets_world: &mut DerivedMemoryBudgetsWorld,
    start: u64,
    end: u64,
    size: u64,
) -> TestResult {
    let body = "a".repeat(usize::try_from(size)?);
    derived_memory_budgets_world.send_first_frames_for_range(start, end, &body)
}

#[when("a derived-budget first frame for key {key:u64} with body {body:string} arrives")]
fn when_derived_budget_first_frame(
    derived_memory_budgets_world: &mut DerivedMemoryBudgetsWorld,
    key: u64,
    body: String,
) -> TestResult {
    derived_memory_budgets_world.send_first_frame(key, &body)
}

#[when(
    "a derived-budget final continuation for key {key:u64} sequence {sequence:u32} with body \
     {body:string} arrives"
)]
fn when_derived_budget_final_continuation(
    derived_memory_budgets_world: &mut DerivedMemoryBudgetsWorld,
    key: u64,
    sequence: u32,
    body: String,
) -> TestResult {
    derived_memory_budgets_world.send_final_continuation_frame(key, sequence, &body)
}

#[then("the derived-budget connection terminates with an error")]
fn then_derived_budget_connection_terminates(
    derived_memory_budgets_world: &mut DerivedMemoryBudgetsWorld,
) -> TestResult {
    derived_memory_budgets_world.assert_connection_aborted()
}

#[then("derived-budget payload {expected:string} is eventually received")]
fn then_derived_budget_payload_received(
    derived_memory_budgets_world: &mut DerivedMemoryBudgetsWorld,
    expected: String,
) -> TestResult {
    derived_memory_budgets_world.assert_payload_received(&expected)
}

#[then("no derived-budget connection error is recorded")]
fn then_no_derived_budget_connection_error(
    derived_memory_budgets_world: &mut DerivedMemoryBudgetsWorld,
) -> TestResult {
    derived_memory_budgets_world.assert_no_connection_error()
}