@@ -191,10 +191,6 @@ create_and_terminate_session(Config) ->
191
191
Terminate = escalus_bosh :session_termination_body (get_bosh_rid (Conn ), Sid ),
192
192
ok = bosh_send_raw (Conn , Terminate ),
193
193
194
- % Assert that correct events have been executed
195
- [instrument_helper :assert (Event , Label , fun (#{byte_size := BS }) -> BS > 0 end )
196
- || {Event , Label } <- instrumentation_events (), Event =/= c2s_message_processed ],
197
-
198
194
% % Assert the session was terminated.
199
195
wait_for_zero_bosh_sessions ().
200
196
@@ -353,6 +349,8 @@ interleave_requests(Config) ->
353
349
Msg3 = <<" 3rd!" >>,
354
350
Msg4 = <<" 4th!" >>,
355
351
352
+ TS = instrument_helper :timestamp (),
353
+
356
354
send_message_with_rid (Carol , Geralt , Rid + 1 , Sid , Msg2 ),
357
355
send_message_with_rid (Carol , Geralt , Rid , Sid , Msg1 ),
358
356
@@ -368,8 +366,10 @@ interleave_requests(Config) ->
368
366
escalus :assert (is_chat_message , [Msg4 ],
369
367
escalus_client :wait_for_stanza (Geralt )),
370
368
371
- [instrument_helper :assert (Event , Label , fun (#{byte_size := BS }) -> BS > 0 ;
372
- (#{time := Time }) -> Time > 0 end )
369
+ Pred = fun (#{byte_size := BS }) -> BS > 0 ;
370
+ (#{time := Time }) -> Time > 0
371
+ end ,
372
+ [instrument_helper :assert (Event , Label , Pred , #{min_timestamp => TS })
373
373
|| {Event , Label } <- instrumentation_events ()],
374
374
375
375
true = is_bosh_connected (Carol )
0 commit comments