Lines Matching refs:tx
49 let (tx, rx) = channel::<Result<u32, ErrorCode>>(); in construct()
53 tx, in construct()
60 let (tx, rx) = channel::<ErrorCode>(); in pause()
62 Self::Service(ServiceEvent::Pause(uid, task_id, tx)), in pause()
68 let (tx, rx) = channel::<ErrorCode>(); in start()
70 Self::Service(ServiceEvent::Start(uid, task_id, tx)), in start()
76 let (tx, rx) = channel::<ErrorCode>(); in stop()
78 Self::Service(ServiceEvent::Stop(uid, task_id, tx)), in stop()
84 let (tx, rx) = channel::<ErrorCode>(); in remove()
86 Self::Service(ServiceEvent::Remove(uid, task_id, tx)), in remove()
92 let (tx, rx) = channel::<ErrorCode>(); in resume()
94 Self::Service(ServiceEvent::Resume(uid, task_id, tx)), in resume()
100 let (tx, rx) = channel::<DumpAllInfo>(); in dump_all()
101 (Self::Service(ServiceEvent::DumpAll(tx)), Recv::new(rx)) in dump_all()
105 let (tx, rx) = channel::<Option<DumpOneInfo>>(); in dump_one()
107 Self::Service(ServiceEvent::DumpOne(task_id, tx)), in dump_one()
117 let (tx, rx) = channel::<ErrorCode>(); in subscribe()
119 Self::Task(TaskEvent::Subscribe(task_id, token_id, tx)), in subscribe()