Struct ByteStreams 

pub struct ByteStreams<OB, IB> {
    pub outgoing: OB,
    pub incoming: IB,
}

A component that communicates over byte streams (stdin/stdout, sockets, pipes, etc.).

ByteStreams implements the Component trait for any pair of AsyncRead and AsyncWrite streams, handling serialization of JSON-RPC messages to/from newline-delimited JSON. This is the standard way to communicate with external processes or network connections.

Use Cases

• Stdio communication: Connect to agents or proxies via stdin/stdout
• Network sockets: TCP, Unix domain sockets, or other stream-based protocols
• Named pipes: Cross-process communication on the same machine
• File I/O: Reading from and writing to file descriptors

Example

Connecting to an agent via stdio:

use sacp::link::UntypedLink;
use tokio_util::compat::{TokioAsyncReadCompatExt, TokioAsyncWriteCompatExt};

let component = ByteStreams::new(
    tokio::io::stdout().compat_write(),
    tokio::io::stdin().compat(),
);

// Use as a component in a connection
sacp::link::UntypedLink::builder()
    .name("my-client")
    .serve(component)
    .await?;

Fields

outgoing: OB

Outgoing byte stream (where we write serialized messages)

incoming: IB

Incoming byte stream (where we read and parse messages)

Implementations

impl<OB, IB> ByteStreams<OB, IB>

where OB: AsyncWrite + Send + 'static, IB: AsyncRead + Send + 'static,

pub fn new(outgoing: OB, incoming: IB) -> Self

Create a new byte stream transport.

Trait Implementations

impl<OB, IB, L: JrLink> Component<L> for ByteStreams<OB, IB>

where OB: AsyncWrite + Send + 'static, IB: AsyncRead + Send + 'static,

async fn serve(self, client: impl Component<L::ConnectsTo>) -> Result<(), Error>

Serve this component by forwarding to a client component.

fn into_server(self) -> (Channel, BoxFuture<'static, Result<(), Error>>)

Convert this component into a channel endpoint and server future.