Struct tower_lsp::Server

pub struct Server<I, O, S = Nothing> { /* private fields */ }

Server for processing requests and responses on standard I/O or TCP.

Implementations

impl<I, O> Server<I, O, Nothing> where
    I: AsyncRead + Unpin,
    O: AsyncWrite, 

pub fn new(stdin: I, stdout: O) -> Self

Creates a new Server with the given stdin and stdout handles.

Examples

Initialize with a standard I/O transport:

let stdin = tokio::io::stdin();
let stdout = tokio::io::stdout();
let server = Server::new(stdin, stdout);

Initialize with a TCP transport:

let mut listener = tokio::net::TcpListener::bind("127.0.0.1:9257").await?;
let (stream, _) = listener.accept().await?;
let (read, write) = tokio::io::split(stream);
let server = Server::new(read, write);

impl<I, O, S> Server<I, O, S> where
    I: AsyncRead + Unpin,
    O: AsyncWrite,
    S: Stream<Item = Outgoing>, 

pub fn interleave<T>(self, stream: T) -> Server<I, O, T> where
    T: Stream<Item = Outgoing>, 

Interleaves the given stream of messages into stdout together with the responses.

pub async fn serve<T>(self, service: T) where
    T: Service<Incoming, Response = Option<Outgoing>> + Send + 'static,
    T::Error: Into<Box<dyn Error + Send + Sync>>,
    T::Future: Send, 

Spawns the service with messages read through stdin and responses written to stdout.

Trait Implementations

impl<I: Debug, O: Debug, S: Debug> Debug for Server<I, O, S>

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

Formats the value using the given formatter.