equal
deleted
inserted
replaced
21 |
21 |
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 |
|
27 todo!("convert into an IO task"); |
26 |
28 |
27 /*let mut db = Database::new("localhost"); |
29 /*let mut db = Database::new("localhost"); |
28 |
30 |
29 thread::spawn(move || { |
31 thread::spawn(move || { |
30 while let Ok((request_id, task)) = io_rx.recv() { |
32 while let Ok((request_id, task)) = io_rx.recv() { |