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

Function exchange

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

Source from the content-addressed store, hash-verified

1414
1415#[cfg(unix)]
1416async fn exchange(endpoint: &str, frame: &RequestFrame) -> anyhow::Result<ResponseFrame> {
1417 let mut stream = tokio::net::UnixStream::connect(endpoint)
1418 .await
1419 .with_context(|| format!("database owner is not reachable at {endpoint}"))?;
1420 write_frame(&mut stream, frame).await?;
1421 read_frame(&mut stream).await
1422}
1423
1424#[cfg(windows)]
1425async 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