(&self)
| 48 | /// and causing the original waiter to observe a "channel closed" error. |
| 49 | #[inline] |
| 50 | pub fn next_request_id(&self) -> crate::types::RequestId { |
| 51 | crate::types::RequestId::new( |
| 52 | self.request_id_counter |
| 53 | .fetch_add(1, std::sync::atomic::Ordering::Relaxed), |
| 54 | ) |
| 55 | } |
| 56 | |
| 57 | /// Convert an LSN back to wall-clock milliseconds using the anchor map. |
| 58 | /// |
no outgoing calls
no test coverage detected