Struct Server

pub struct Server<I, O, L = ClientSocket> { /* private fields */ }

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

Implementations

impl<I, O, L> Server<I, O, L>

where I: AsyncRead + Unpin, O: AsyncWrite, L: Loopback, <L::ResponseSink as Sink<Response>>::Error: Error,

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

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

pub fn concurrency_level(self, max: usize) -> Self

Sets the server concurrency limit to max.

This setting specifies how many incoming requests may be processed concurrently. Setting this value to 1 forces all requests to be processed sequentially, thereby implicitly disabling support for the $/cancelRequest notification.

If not explicitly specified, max defaults to 4.

Preference over standard tower middleware

The ConcurrencyLimit and Buffer middlewares provided by tower rely on tokio::spawn in common usage, while this library aims to be executor agnostic and to support exotic targets currently incompatible with tokio, such as WASM. As such, Server includes its own concurrency facilities that don’t require a global executor to be present.

pub async fn serve<T>(self, service: T)

where T: Service<Request, Response = Option<Response>> + 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, L: Debug> Debug for Server<I, O, L>

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

Formats the value using the given formatter.