MCPcopy Create free account
hub / github.com/atomicdotdev/atomic / exchange

Function exchange

atomic-cli/src/commands/agent/owner.rs:1381–1387  ·  view source on GitHub ↗
(endpoint: &str, frame: &RequestFrame)

Source from the content-addressed store, hash-verified

1379
1380#[cfg(unix)]
1381async 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)]
1390async fn exchange(endpoint: &str, frame: &RequestFrame) -> anyhow::Result<ResponseFrame> {

Callers 1

requestFunction · 0.85

Calls 4

write_frameFunction · 0.85
read_frameFunction · 0.85
connect_owner_pipeFunction · 0.85
with_contextMethod · 0.45

Tested by

no test coverage detected