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 ConnectTo 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 agent_client_protocol::UntypedRole;
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
agent_client_protocol::UntypedRole.builder()
    .name("my-client")
    .connect_to(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, R: Role> ConnectTo<R> for ByteStreams<OB, IB>

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

async fn connect_to( self, client: impl ConnectTo<R::Counterpart>, ) -> Result<(), Error>

Serve this component by forwarding to a client component.

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

Convert this component into a channel endpoint and server future.

impl<OB: Debug, IB: Debug> Debug for ByteStreams<OB, IB>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.