(endpoint: &str, frame: &RequestFrame)
| 1379 | |
| 1380 | #[cfg(unix)] |
| 1381 | async fn exchange(endpoint: &str, frame: &RequestFrame) -> anyhow::Result<ResponseFrame> { |
| 1382 | let mut stream = tokio::net::UnixStream::connect(endpoint) |
| 1383 | .await |
| 1384 | .with_context(|| format!("database owner is not reachable at {endpoint}"))?; |
| 1385 | write_frame(&mut stream, frame).await?; |
| 1386 | read_frame(&mut stream).await |
| 1387 | } |
| 1388 | |
| 1389 | #[cfg(windows)] |
| 1390 | async fn exchange(endpoint: &str, frame: &RequestFrame) -> anyhow::Result<ResponseFrame> { |
no test coverage detected