18 use std::task::Poll;
260     async fn run(mut self, task: Option<TaskFn<S::StoreData>>, req_id: Option<u64>) {  in run()
261         if let Err(error) = self.run_(task, req_id).await {  in run()
268         task: Option<TaskFn<S::StoreData>>,  in run_()
323             let accept_task = |task: TaskFn<S::StoreData>,  in run_()
344                     (task)(accessor, proxy).await;  in run_()
349             if let Some(task) = task {  in run_()
350                 accept_task(task, &mut futures, &mut reuse_count);  in run_()
441                     Some(Ok(task)) => {  in run_()
442                         accept_task(task, &mut futures, &mut reuse_count);  in run_()
574     pub fn spawn(&self, req_id: Option<u64>, task: TaskFn<S::StoreData>) {  in spawn()
583                     self.start_worker(Some(task), req_id);  in spawn()
585                     self.0.task_queue.push(task);  in spawn()
628     fn start_worker(&self, task: Option<TaskFn<S::StoreData>>, req_id: Option<u64>) {  in start_worker()
634             .run(task, req_id),  in start_worker()