Searched refs:tick (Results 1 – 13 of 13) sorted by relevance
189 pub async fn tick(&self) -> usize { in tick() method209 self.tick().await; in process()
212 let _ = ticker.tick().await; in main()280 let _ = ticker.tick().await; in main()
218 let _ = ticker.tick().await; in main()291 let _ = ticker.tick().await; in main()
17 n_sum += br.tick().await; in bridge_process_at_least_one()72 br.tick().await; in create_new_association_pair()136 br.tick().await; in close_association_pair()503 br.tick().await; in test_data_channel_buffered_amount()
60 _ = ticker.tick() =>{ in run()
98 _ = ticker.tick() =>{ in run()
130 _ = ticker.tick() =>{ in run()
129 _ = ticker.tick() =>{ in run()
69 br.tick().await; in create_new_association_pair()139 br.tick().await; in close_association_pair()162 let n = br.tick().await; in flush_buffers()668 br.tick().await; in test_assoc_reliable_retransmission()1361 br.tick().await; in test_assoc_congestion_control_fast_retransmission()1469 let n = br.tick().await; in test_assoc_congestion_control_congestion_avoidance()1607 let n = br.tick().await; in test_assoc_congestion_control_slow_reader()
409 int.tick().await; in main()
55 _ = interval.tick() => { in start()
408 let _ = ticker.tick().await; in write_video_to_track()
209 _ = cleanup_ticker.tick() => { in run_stats_reducer()