(
processor: FirewheelProcessorInner,
drop_tx: ringbuf::HeapProd<FirewheelProcessorInner>,
drop_flag: Arc<AtomicBool>,
)
| 69 | |
| 70 | impl FirewheelProcessor { |
| 71 | pub(crate) fn new( |
| 72 | processor: FirewheelProcessorInner, |
| 73 | drop_tx: ringbuf::HeapProd<FirewheelProcessorInner>, |
| 74 | drop_flag: Arc<AtomicBool>, |
| 75 | ) -> Self { |
| 76 | Self { |
| 77 | inner: Some(processor), |
| 78 | drop_tx, |
| 79 | drop_flag, |
| 80 | } |
| 81 | } |
| 82 | |
| 83 | pub fn process( |
| 84 | &mut self, |
nothing calls this directly
no test coverage detected