13 async fn bridge_process_at_least_one(br: &Arc<Bridge>) {  in bridge_process_at_least_one()
17         n_sum += br.tick().await;  in bridge_process_at_least_one()
18         if br.len(0).await == 0 && br.len(1).await == 0 && n_sum > 0 {  in bridge_process_at_least_one()
25     br: &Arc<Bridge>,  in create_new_association_pair()
72         br.tick().await;  in create_new_association_pair()
105     br: &Arc<Bridge>,  in close_association_pair()
136         br.tick().await;  in close_association_pair()
177     let (br, ca, cb) = Bridge::new(0, None, None);  in pr_ordered_unordered_test()
179     let (a0, a1) = create_new_association_pair(&br, Arc::new(ca), Arc::new(cb)).await?;  in pr_ordered_unordered_test()
189     bridge_process_at_least_one(&br).await;  in pr_ordered_unordered_test()
193     bridge_process_at_least_one(&br).await;  in pr_ordered_unordered_test()
222     br.drop_offset(0, 0, 1).await; // drop the first packet on the wire  in pr_ordered_unordered_test()
224         br.reorder(0).await;  in pr_ordered_unordered_test()
228     bridge_process_at_least_one(&br).await;  in pr_ordered_unordered_test()
252     bridge_process_at_least_one(&br).await;  in pr_ordered_unordered_test()
254     close_association_pair(&br, a0, a1).await;  in pr_ordered_unordered_test()
264     let (br, ca, cb) = Bridge::new(0, None, None);  in test_data_channel_channel_type_reliable_ordered()
266     let (a0, a1) = create_new_association_pair(&br, Arc::new(ca), Arc::new(cb)).await?;  in test_data_channel_channel_type_reliable_ordered()
276     bridge_process_at_least_one(&br).await;  in test_data_channel_channel_type_reliable_ordered()
280     bridge_process_at_least_one(&br).await;  in test_data_channel_channel_type_reliable_ordered()
285     br.reorder_next_nwrites(0, 2); // reordering on the wire  in test_data_channel_channel_type_reliable_ordered()
295     bridge_process_at_least_one(&br).await;  in test_data_channel_channel_type_reliable_ordered()
315     bridge_process_at_least_one(&br).await;  in test_data_channel_channel_type_reliable_ordered()
317     close_association_pair(&br, a0, a1).await;  in test_data_channel_channel_type_reliable_ordered()
327     let (br, ca, cb) = Bridge::new(0, None, None);  in test_data_channel_channel_type_reliable_unordered()
329     let (a0, a1) = create_new_association_pair(&br, Arc::new(ca), Arc::new(cb)).await?;  in test_data_channel_channel_type_reliable_unordered()
339     bridge_process_at_least_one(&br).await;  in test_data_channel_channel_type_reliable_unordered()
343     bridge_process_at_least_one(&br).await;  in test_data_channel_channel_type_reliable_unordered()
364     br.reorder(0).await; // reordering on the wire  in test_data_channel_channel_type_reliable_unordered()
365     bridge_process_at_least_one(&br).await;  in test_data_channel_channel_type_reliable_unordered()
387     bridge_process_at_least_one(&br).await;  in test_data_channel_channel_type_reliable_unordered()
389     close_association_pair(&br, a0, a1).await;  in test_data_channel_channel_type_reliable_unordered()
427     let (br, ca, cb) = Bridge::new(0, None, None);  in test_data_channel_buffered_amount()
429     let (a0, a1) = create_new_association_pair(&br, Arc::new(ca), Arc::new(cb)).await?;  in test_data_channel_buffered_amount()
442     bridge_process_at_least_one(&br).await;  in test_data_channel_buffered_amount()
446     bridge_process_at_least_one(&br).await;  in test_data_channel_buffered_amount()
449         bridge_process_at_least_one(&br).await;  in test_data_channel_buffered_amount()
460     bridge_process_at_least_one(&br).await;  in test_data_channel_buffered_amount()
503         br.tick().await;  in test_data_channel_buffered_amount()
512     bridge_process_at_least_one(&br).await;  in test_data_channel_buffered_amount()
519     close_association_pair(&br, a0, a1).await;  in test_data_channel_buffered_amount()
531     let (br, ca, cb) = Bridge::new(0, None, None);  in test_stats()
533     let (a0, a1) = create_new_association_pair(&br, Arc::new(ca), Arc::new(cb)).await?;  in test_stats()
543     bridge_process_at_least_one(&br).await;  in test_stats()
547     bridge_process_at_least_one(&br).await;  in test_stats()
579     bridge_process_at_least_one(&br).await;  in test_stats()
613     bridge_process_at_least_one(&br).await;  in test_stats()
615     close_association_pair(&br, a0, a1).await;  in test_stats()
625     let (br, ca, cb) = Bridge::new(0, None, None);  in test_poll_data_channel()
627     let (a0, a1) = create_new_association_pair(&br, Arc::new(ca), Arc::new(cb)).await?;  in test_poll_data_channel()
637     bridge_process_at_least_one(&br).await;  in test_poll_data_channel()
641     bridge_process_at_least_one(&br).await;  in test_poll_data_channel()
653     bridge_process_at_least_one(&br).await;  in test_poll_data_channel()
668     bridge_process_at_least_one(&br).await;  in test_poll_data_channel()
670     close_association_pair(&br, a0, a1).await;  in test_poll_data_channel()