@@ -21,14 +21,88 @@ To run this example:
21
21
<!-- STEP
22
22
name: Run Subscriber
23
23
output_match_mode: substring
24
- match_order: none
24
+ match_order: sequential
25
25
expected_stdout_lines:
26
- - '== APP - rust-subscriber == Message: 0 => hello from rust!'
27
- - '== APP - rust-subscriber == Content-Type: text/plain'
28
- - '== APP - rust-subscriber == Message: 1 => hello from rust!'
29
- - '== APP - rust-subscriber == Content-Type: text/plain'
30
- - '== APP - rust-subscriber == Message: 2 => hello from rust!'
31
- - '== APP - rust-subscriber == Content-Type: text/plain'
26
+ - '== APP - rust-subscriber == Topic A - Order {'
27
+ - '== APP - rust-subscriber == order_number: 0,'
28
+ - '== APP - rust-subscriber == order_details: "Count is 0",'
29
+ - '== APP - rust-subscriber == }'
30
+ - '== APP - rust-subscriber == Topic A - Order {'
31
+ - '== APP - rust-subscriber == order_number: 1,'
32
+ - '== APP - rust-subscriber == order_details: "Count is 1",'
33
+ - '== APP - rust-subscriber == }'
34
+ - '== APP - rust-subscriber == Topic A - Order {'
35
+ - '== APP - rust-subscriber == order_number: 2,'
36
+ - '== APP - rust-subscriber == order_details: "Count is 2",'
37
+ - '== APP - rust-subscriber == }'
38
+ - '== APP - rust-subscriber == Topic A - Order {'
39
+ - '== APP - rust-subscriber == order_number: 3,'
40
+ - '== APP - rust-subscriber == order_details: "Count is 3",'
41
+ - '== APP - rust-subscriber == }'
42
+ - '== APP - rust-subscriber == Topic A - Order {'
43
+ - '== APP - rust-subscriber == order_number: 4,'
44
+ - '== APP - rust-subscriber == order_details: "Count is 4",'
45
+ - '== APP - rust-subscriber == }'
46
+ - '== APP - rust-subscriber == Topic A - Order {'
47
+ - '== APP - rust-subscriber == order_number: 5,'
48
+ - '== APP - rust-subscriber == order_details: "Count is 5",'
49
+ - '== APP - rust-subscriber == }'
50
+ - '== APP - rust-subscriber == Topic A - Order {'
51
+ - '== APP - rust-subscriber == order_number: 6,'
52
+ - '== APP - rust-subscriber == order_details: "Count is 6",'
53
+ - '== APP - rust-subscriber == }'
54
+ - '== APP - rust-subscriber == Topic A - Order {'
55
+ - '== APP - rust-subscriber == order_number: 7,'
56
+ - '== APP - rust-subscriber == order_details: "Count is 7",'
57
+ - '== APP - rust-subscriber == }'
58
+ - '== APP - rust-subscriber == Topic A - Order {'
59
+ - '== APP - rust-subscriber == order_number: 8,'
60
+ - '== APP - rust-subscriber == order_details: "Count is 8",'
61
+ - '== APP - rust-subscriber == }'
62
+ - '== APP - rust-subscriber == Topic A - Order {'
63
+ - '== APP - rust-subscriber == order_number: 9,'
64
+ - '== APP - rust-subscriber == order_details: "Count is 9",'
65
+ - '== APP - rust-subscriber == }'
66
+ - '== APP - rust-subscriber == Topic B - Refund {'
67
+ - '== APP - rust-subscriber == order_number: 0,'
68
+ - '== APP - rust-subscriber == refund_amount: 1200,'
69
+ - '== APP - rust-subscriber == }'
70
+ - '== APP - rust-subscriber == Topic B - Refund {'
71
+ - '== APP - rust-subscriber == order_number: 1,'
72
+ - '== APP - rust-subscriber == refund_amount: 1200,'
73
+ - '== APP - rust-subscriber == }'
74
+ - '== APP - rust-subscriber == Topic B - Refund {'
75
+ - '== APP - rust-subscriber == order_number: 2,'
76
+ - '== APP - rust-subscriber == refund_amount: 1200,'
77
+ - '== APP - rust-subscriber == }'
78
+ - '== APP - rust-subscriber == Topic B - Refund {'
79
+ - '== APP - rust-subscriber == order_number: 3,'
80
+ - '== APP - rust-subscriber == refund_amount: 1200,'
81
+ - '== APP - rust-subscriber == }'
82
+ - '== APP - rust-subscriber == Topic B - Refund {'
83
+ - '== APP - rust-subscriber == order_number: 4,'
84
+ - '== APP - rust-subscriber == refund_amount: 1200,'
85
+ - '== APP - rust-subscriber == }'
86
+ - '== APP - rust-subscriber == Topic B - Refund {'
87
+ - '== APP - rust-subscriber == order_number: 5,'
88
+ - '== APP - rust-subscriber == refund_amount: 1200,'
89
+ - '== APP - rust-subscriber == }'
90
+ - '== APP - rust-subscriber == Topic B - Refund {'
91
+ - '== APP - rust-subscriber == order_number: 6,'
92
+ - '== APP - rust-subscriber == refund_amount: 1200,'
93
+ - '== APP - rust-subscriber == }'
94
+ - '== APP - rust-subscriber == Topic B - Refund {'
95
+ - '== APP - rust-subscriber == order_number: 7,'
96
+ - '== APP - rust-subscriber == refund_amount: 1200,'
97
+ - '== APP - rust-subscriber == }'
98
+ - '== APP - rust-subscriber == Topic B - Refund {'
99
+ - '== APP - rust-subscriber == order_number: 8,'
100
+ - '== APP - rust-subscriber == refund_amount: 1200,'
101
+ - '== APP - rust-subscriber == }'
102
+ - '== APP - rust-subscriber == Topic B - Refund {'
103
+ - '== APP - rust-subscriber == order_number: 9,'
104
+ - '== APP - rust-subscriber == refund_amount: 1200,'
105
+ - '== APP - rust-subscriber == }'
32
106
- '== APP - rust-publisher == messages published'
33
107
background: true
34
108
sleep: 30
@@ -54,4 +128,4 @@ dapr run --app-id rust-subscriber --app-protocol grpc --app-port 50051 cargo run
54
128
2 . Run the publisher with dapr
55
129
``` bash
56
130
dapr run --app-id rust-publisher --app-protocol grpc cargo run -- --example publisher
57
- ```
131
+ ```
0 commit comments