(&mut self, req: Uri)
| 126 | Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'static>>; |
| 127 | |
| 128 | fn call(&mut self, req: Uri) -> Self::Future { |
| 129 | let fut = async move { |
| 130 | let (cid, port) = parse_vsock_host(&req)?; |
| 131 | VsockStream::connect(cid, port).await |
| 132 | }; |
| 133 | |
| 134 | Box::pin(fut) |
| 135 | } |
| 136 | |
| 137 | fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { |
| 138 | Poll::Ready(Ok(())) |
nothing calls this directly
no test coverage detected