Searched refs:next_async_interruptable (Results 1 – 3 of 3) sorted by relevance
358 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_queue()410 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_reporting_queue()457 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_stats_queue()644 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_ws_data_queue()
428 pub async fn next_async_interruptable( in next_async_interruptable() method
681 .next_async_interruptable(&mut queue_evt, &mut stop_rx) in process_tx_queue()1348 let mut avail_desc = match queue.next_async_interruptable(queue_evt, stop_rx).await { in write_bytes_to_queue_interruptable()