Searched defs:AtomicBool (Results 1 – 6 of 6) sorted by relevance
| /base/request/request/services/src/task/ |
| D | upload.rs | 154 abort_flag: Arc<AtomicBool>, in build_stream_request()
189 abort_flag: Arc<AtomicBool>, in build_multipart_request()
233 abort_flag: Arc<AtomicBool>, in build_batch_multipart_request()
386 pub(crate) async fn upload(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in upload()
416 abort_flag: Arc<AtomicBool>, in upload_inner()
474 abort_flag: Arc<AtomicBool>, in upload_one_file()
|
| D | download.rs | 60 abort_flag: Arc<AtomicBool>, in build_downloader()
72 pub(crate) async fn download(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in download()
113 abort_flag: Arc<AtomicBool>, in download_inner()
|
| /base/request/request/services/src/manage/scheduler/queue/ |
| D | running_task.rs | 45 pub(crate) async fn run(self, abort_flag: Arc<AtomicBool>) { in run()
|
| D | mod.rs | 265 fn new(abort_flag: Arc<AtomicBool>, join_handle: JoinHandle<()>) -> Self { in new()
|
| /base/request/request/services/src/service/ |
| D | stub.rs | 45 remote_busy: Arc<AtomicBool>, in new()
|
| /base/request/request/services/src/service/notification_bar/ |
| D | publish.rs | 71 pub(crate) fn register_task(&self, task: &RequestTask) -> Arc<AtomicBool> { in register_task()
|