|
@@ -1167,10 +1167,11 @@ t_retry_batch(_Config) ->
|
|
|
%% each time should be the original batch (no duplicate
|
|
%% each time should be the original batch (no duplicate
|
|
|
%% elements or reordering).
|
|
%% elements or reordering).
|
|
|
ExpectedSeenPayloads = lists:flatten(lists:duplicate(4, Payloads)),
|
|
ExpectedSeenPayloads = lists:flatten(lists:duplicate(4, Payloads)),
|
|
|
- ?assertEqual(
|
|
|
|
|
- ExpectedSeenPayloads,
|
|
|
|
|
- ?projection(n, ?of_kind(connector_demo_batch_inc_individual, Trace))
|
|
|
|
|
|
|
+ Trace1 = lists:sublist(
|
|
|
|
|
+ ?projection(n, ?of_kind(connector_demo_batch_inc_individual, Trace)),
|
|
|
|
|
+ length(ExpectedSeenPayloads)
|
|
|
),
|
|
),
|
|
|
|
|
+ ?assertEqual(ExpectedSeenPayloads, Trace1),
|
|
|
?assertMatch(
|
|
?assertMatch(
|
|
|
[#{n := ExpectedCount}],
|
|
[#{n := ExpectedCount}],
|
|
|
?of_kind(connector_demo_inc_counter, Trace)
|
|
?of_kind(connector_demo_inc_counter, Trace)
|