equal
deleted
inserted
replaced
22 impl IoThread { |
22 impl IoThread { |
23 pub fn new(waker: Waker) -> Self { |
23 pub fn new(waker: Waker) -> Self { |
24 let (core_tx, io_rx) = mpsc::channel(); |
24 let (core_tx, io_rx) = mpsc::channel(); |
25 let (io_tx, core_rx) = mpsc::channel(); |
25 let (io_tx, core_rx) = mpsc::channel(); |
26 |
26 |
27 todo!("convert into an IO task"); |
27 //todo!("convert into an IO task"); |
28 |
28 |
29 /*let mut db = Database::new("localhost"); |
29 /*let mut db = Database::new("localhost"); |
30 |
30 |
31 thread::spawn(move || { |
31 thread::spawn(move || { |
32 while let Ok((request_id, task)) = io_rx.recv() { |
32 while let Ok((request_id, task)) = io_rx.recv() { |