Searched defs:RequestTask (Results 1 – 8 of 8) sorted by relevance
/ohos5.0/base/request/request/services/src/task/ |
H A D | upload.rs | 41 pub(crate) fn new(task: Arc<RequestTask>, index: usize) -> Self { in new() 141 task: Arc<RequestTask>, in build_stream_request() 176 task: Arc<RequestTask>, in build_multipart_request() 220 task: &Arc<RequestTask>, in build_request_common() 239 impl RequestTask { implementation 275 pub(crate) async fn upload(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in upload() 304 task: Arc<RequestTask>, in upload_inner() 356 task: Arc<RequestTask>, in upload_one_file() 362 F: Fn(Arc<RequestTask>, usize, Arc<AtomicBool>) -> Option<Request>, in upload_one_file() 460 fn build_task(config: TaskConfig) -> Arc<RequestTask> { in build_task()
|
H A D | download.rs | 58 task: Arc<RequestTask>, in build_downloader() 72 pub(crate) async fn download(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in download() 97 impl RequestTask { impl 113 task: Arc<RequestTask>, in download_inner() 292 fn build_task(config: TaskConfig) -> Arc<RequestTask> { in build_task()
|
H A D | request_task.rs | 46 pub(crate) struct RequestTask { struct 67 impl RequestTask { impl 128 impl RequestTask { impl 135 ) -> RequestTask { in new() 194 ) -> Result<RequestTask, ErrorCode> { in new_by_info()
|
H A D | operator.rs | 44 pub(crate) fn new(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) -> Self { in new()
|
/ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
H A D | running_task.rs | 36 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self { in new()
|
H A D | mod.rs | 72 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task()
|
/ohos5.0/base/request/request/services/src/manage/scheduler/ |
H A D | mod.rs | 90 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task()
|
/ohos5.0/base/request/request/services/src/manage/ |
H A D | database.rs | 563 ) -> Result<Arc<RequestTask>, ErrorCode> { in get_task()
|