(&mut self, _buffer: VecDeque<User>)
| 78 | async fn terminate(&mut self) {} |
| 79 | |
| 80 | async fn drain(&mut self, _buffer: VecDeque<User>) {} |
| 81 | |
| 82 | async fn fill_buffer(&mut self, buffer_size: usize) -> Result<VecDeque<User>, Terminate> { |
| 83 |
nothing calls this directly
no outgoing calls
no test coverage detected