Get a job reply, blocking until one is available.
(&mut self)
| 107 | |
| 108 | /// Get a job reply, blocking until one is available. |
| 109 | pub fn get(&mut self) -> Option<Reply> { |
| 110 | self.reply_rx.recv().ok() |
| 111 | } |
| 112 | } |
| 113 | |
| 114 | /// Spawn a heartbeat thread which sends ticks down the reply channel every second. |