Struct ast_grep_lsp::LspService

pub struct LspService<S> { /* private fields */ }

Service abstraction for the Language Server Protocol.

This service takes an incoming JSON-RPC message as input and produces an outgoing message as output. If the incoming message is a server notification or a client response, then the corresponding response will be None.

This implements [tower::Service] in order to remain independent from the underlying transport and to facilitate further abstraction with middleware.

Pending requests can be canceled by issuing a $/cancelRequest notification.

The service shuts down and stops serving requests after the exit notification is received.

Implementations

impl<S> LspService<S>where S: LanguageServer,

pub fn new<F>(init: F) -> (LspService<S>, ClientSocket)where F: FnOnce(Client) -> S,

Creates a new LspService with the given server backend, also returning a channel for server-to-client communication.

pub fn build<F>(init: F) -> LspServiceBuilder<S>where F: FnOnce(Client) -> S,

Starts building a new LspService.

Returns an LspServiceBuilder, which allows adding custom JSON-RPC methods to the server.

pub fn inner(&self) -> &S

Returns a reference to the inner server.

Trait Implementations

impl<S> Debug for LspService<S>where S: Debug,

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

Formats the value using the given formatter.

impl<S> Service<Request> for LspService<S>where S: LanguageServer,

type Response = Option<Response>

Responses given by the service.

type Error = ExitedError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<LspService<S> as Service<Request>>::Response, <LspService<S> as Service<Request>>::Error>> + Send>>

The future response value.

fn poll_ready( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), <LspService<S> as Service<Request>>::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Request) -> <LspService<S> as Service<Request>>::Future

Process the request and return the response asynchronously.