Struct Lines 

pub struct Lines<OutgoingSink, IncomingStream> { /* private fields */ }

A component that communicates over line streams.

Lines implements the ConnectTo trait for any pair of line-based streams (a Stream<Item = io::Result<String>> for incoming and a Sink<String> for outgoing), handling serialization of JSON-RPC messages to/from newline-delimited JSON. An incoming line may contain one JSON-RPC message or a non-empty batch array. Batch entries are dispatched individually in source order, and responses to the batch are collected into one response-array line. SDK-initiated requests and notifications remain individual messages.

This is a lower-level primitive than ByteStreams that enables interception and transformation of individual lines before they are parsed or after they are serialized. This is particularly useful for debugging, logging, or implementing custom line-based protocols.

Use Cases

• Line-by-line logging: Intercept and log each line before parsing
• Custom protocols: Transform lines before/after JSON-RPC processing
• Debugging: Inspect raw message strings
• Line filtering: Skip or modify specific messages

Most users should use ByteStreams instead, which provides a simpler interface for byte-based I/O.

Implementations

impl<OutgoingSink, IncomingStream> Lines<OutgoingSink, IncomingStream>

where OutgoingSink: Sink<String, Error = Error> + Send + 'static, IncomingStream: Stream<Item = Result<String>> + Send + 'static,

pub fn new(outgoing: OutgoingSink, incoming: IncomingStream) -> Self

Create a new line stream transport.

Trait Implementations

impl<OutgoingSink, IncomingStream, R: Role> ConnectTo<R> for Lines<OutgoingSink, IncomingStream>

where OutgoingSink: Sink<String, Error = Error> + Send + 'static, IncomingStream: Stream<Item = Result<String>> + Send + 'static,

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

Connect this component to another component.

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

Convert this component into a channel endpoint and connection future.

impl<OutgoingSink: Debug, IncomingStream: Debug> Debug for Lines<OutgoingSink, IncomingStream>

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

Formats the value using the given formatter.