Struct async_lsp::router::Router

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

Implementations

impl<S> Router<S>

pub fn new(state: S) -> Self

pub fn request<R: Request, Fut>( &mut self, handler: impl Fn(&mut S, R::Params) -> Fut + Send + 'static ) -> &mut Selfwhere Fut: Future<Output = Result<R::Result, ResponseError>> + Send + 'static,

pub fn notification<N: Notification>( &mut self, handler: impl Fn(&mut S, N::Params) -> ControlFlow<Result<()>> + Send + 'static ) -> &mut Self

pub fn event<E: Send + 'static>( &mut self, handler: impl Fn(&mut S, E) -> ControlFlow<Result<()>> + Send + 'static ) -> &mut Self

pub fn unhandled_request<Fut>( &mut self, handler: impl Fn(&mut S, AnyRequest) -> Fut + Send + 'static ) -> &mut Selfwhere Fut: Future<Output = Result<JsonValue, ResponseError>> + Send + 'static,

pub fn unhandled_notification( &mut self, handler: impl Fn(&mut S, AnyNotification) -> ControlFlow<Result<()>> + Send + 'static ) -> &mut Self

pub fn unhandled_event( &mut self, handler: impl Fn(&mut S, AnyEvent) -> ControlFlow<Result<()>> + Send + 'static ) -> &mut Self

impl<S> Router<S>where S: LanguageServer<NotifyResult = ControlFlow<Result<()>>>, ResponseError: From<S::Error>,

pub fn from_language_server(state: S) -> Self

impl<S> Router<S>where S: LanguageClient<NotifyResult = ControlFlow<Result<()>>>, ResponseError: From<S::Error>,

pub fn from_language_client(state: S) -> Self

Trait Implementations

impl<S: Default> Default for Router<S>

fn default() -> Self

Returns the “default value” for a type.

impl<S> LspService for Router<S>

fn notify(&mut self, notif: AnyNotification) -> ControlFlow<Result<()>>

fn emit(&mut self, event: AnyEvent) -> ControlFlow<Result<()>>

impl<S> Service<AnyRequest> for Router<S>

type Response = Value

Responses given by the service.

type Error = ResponseError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Value, ResponseError>> + Send + 'static, Global>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

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

fn call(&mut self, req: AnyRequest) -> Self::Future

Process the request and return the response asynchronously.