(&self, timeout: &Pollable)
| 216 | |
| 217 | impl OutgoingDatagramStream { |
| 218 | fn blocking_check_send(&self, timeout: &Pollable) -> Result<u64, ErrorCode> { |
| 219 | let sub = self.subscribe(); |
| 220 | |
| 221 | loop { |
| 222 | match self.check_send() { |
| 223 | Ok(0) => sub.block_until(timeout)?, |
| 224 | result => return result, |
| 225 | } |
| 226 | } |
| 227 | } |
| 228 | |
| 229 | pub fn blocking_send(&self, mut datagrams: &[OutgoingDatagram]) -> Result<(), ErrorCode> { |
| 230 | let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS); |
no test coverage detected