Lines Matching refs:StoreData
152 type StoreData: Send; typedef
159 fn new_store(&self, req_id: Option<u64>) -> Result<StoreBundle<Self::StoreData>>; in new_store() argument
185 instance_pre: ProxyPre<S::StoreData>,
187 task_queue: Queue<TaskFn<S::StoreData>>,
260 async fn run(mut self, task: Option<TaskFn<S::StoreData>>, req_id: Option<u64>) { in run() argument
268 task: Option<TaskFn<S::StoreData>>, in run_() argument
323 let accept_task = |task: TaskFn<S::StoreData>, in run_()
552 pub fn new(state: S, instance_pre: ProxyPre<S::StoreData>) -> Self { in new()
574 pub fn spawn(&self, req_id: Option<u64>, task: TaskFn<S::StoreData>) { in spawn() argument
624 pub fn instance_pre(&self) -> &ProxyPre<S::StoreData> { in instance_pre() argument
628 fn start_worker(&self, task: Option<TaskFn<S::StoreData>>, req_id: Option<u64>) { in start_worker() argument