Struct Lines 

pub struct Lines<OutgoingSink, IncomingStream> {
    pub outgoing: OutgoingSink,
    pub incoming: IncomingStream,
}

A component that communicates over line streams.

Lines implements the Component 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.

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.

Fields

outgoing: OutgoingSink

Outgoing line sink (where we write serialized JSON-RPC messages)

incoming: IncomingStream

Incoming line stream (where we read and parse JSON-RPC messages)

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> Component for Lines<OutgoingSink, IncomingStream>

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

async fn serve(self, client: impl Component) -> 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.