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

//! Step definitions for inbound message assembly integration scenarios.

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

use crate::fixtures::message_assembly_inbound::{MessageAssemblyInboundWorld, TestResult};

#[given("an inbound app with message assembly timeout {timeout_ms:u64} milliseconds")]
fn given_inbound_app(
    message_assembly_inbound_world: &mut MessageAssemblyInboundWorld,
    timeout_ms: u64,
) -> TestResult {
    message_assembly_inbound_world.start_app(timeout_ms)
}

#[when("a first frame for key {key:u64} with body {body:string} arrives")]
fn when_first_frame_arrives(
    message_assembly_inbound_world: &mut MessageAssemblyInboundWorld,
    key: u64,
    body: String,
) -> TestResult {
    message_assembly_inbound_world.send_first_frame(key, &body)
}

#[when(
    "a continuation frame for key {key:u64} sequence {sequence:u32} with body {body:string} \
     arrives"
)]
fn when_continuation_frame_arrives(
    message_assembly_inbound_world: &mut MessageAssemblyInboundWorld,
    key: u64,
    sequence: u32,
    body: String,
) -> TestResult {
    message_assembly_inbound_world.send_continuation_frame(key, sequence, &body)
}

#[when(
    "a final continuation frame for key {key:u64} sequence {sequence:u32} with body {body:string} \
     arrives"
)]
fn when_final_continuation_frame_arrives(
    message_assembly_inbound_world: &mut MessageAssemblyInboundWorld,
    key: u64,
    sequence: u32,
    body: String,
) -> TestResult {
    message_assembly_inbound_world.send_final_continuation_frame(key, sequence, &body)
}

#[when("time advances by {millis:u64} milliseconds")]
fn when_time_advances(
    message_assembly_inbound_world: &mut MessageAssemblyInboundWorld,
    millis: u64,
) -> TestResult {
    message_assembly_inbound_world.wait_millis(millis)
}

#[then("the handler eventually receives payload {payload:string}")]
fn then_handler_receives_payload(
    message_assembly_inbound_world: &mut MessageAssemblyInboundWorld,
    payload: String,
) -> TestResult {
    message_assembly_inbound_world.assert_received_payload(&payload)
}

#[then("the handler receives {count:usize} payloads")]
#[then("the handler receives {count:usize} payload")]
fn then_handler_receives_count(
    message_assembly_inbound_world: &mut MessageAssemblyInboundWorld,
    count: usize,
) -> TestResult {
    message_assembly_inbound_world.assert_received_count(count)
}

#[then("no send error is recorded")]
fn then_no_send_error(
    message_assembly_inbound_world: &mut MessageAssemblyInboundWorld,
) -> TestResult {
    message_assembly_inbound_world.assert_no_send_error()
}