(config: &HttpConfig)
| 485 | Err(TrySendError::Disconnected(work)) => { |
| 486 | self.rejected_requests = self.rejected_requests.saturating_add(1); |
| 487 | Err(HttpSubmitError::new( |
| 488 | id, |
| 489 | work.request.url, |
| 490 | HttpSubmitErrorKind::QueueClosed, |
| 491 | "http worker queue closed", |
| 492 | )) |
| 493 | } |
| 494 | } |
| 495 | } |
| 496 | |
| 497 | pub fn get(&mut self, url: impl Into<String>) -> HttpID { |
| 498 | self.request(HttpRequest::get(url)) |
| 499 | } |
| 500 |
no test coverage detected