1 files changed, 45 insertions, 0 deletions

diff --git a/crates/gen_lsp_server/examples/01_gen_lsp_server.rs b/crates/gen_lsp_server/examples/01_gen_lsp_server.rs
new file mode 100644
index 000000000..60c581075
--- /dev/null
+++ b/crates/gen_lsp_server/examples/01_gen_lsp_server.rs
@@ -0,0 +1,45 @@
+use crossbeam_channel::{Sender, Receiver};

+use lsp_types::{

+    ServerCapabilities, InitializeParams,

+    request::{GotoDefinition, GotoDefinitionResponse},

+};

+use gen_lsp_server::{run_server, stdio_transport, handle_shutdown, RawMessage, RawResponse};

+

+fn main() -> Result<(), failure::Error> {

+    let (receiver, sender, io_threads) = stdio_transport();

+    run_server(ServerCapabilities::default(), receiver, sender, main_loop)?;

+    io_threads.join()?;

+    Ok(())

+}

+

+fn main_loop(

+    _params: InitializeParams,

+    receiver: &Receiver<RawMessage>,

+    sender: &Sender<RawMessage>,

+) -> Result<(), failure::Error> {

+    for msg in receiver {

+        match msg {

+            RawMessage::Request(req) => {

+                let req = match handle_shutdown(req, sender) {

+                    None => return Ok(()),

+                    Some(req) => req,

+                };

+                match req.cast::<GotoDefinition>() {

+                    Ok((id, _params)) => {

+                        let resp = RawResponse::ok::<GotoDefinition>(

+                            id,

+                            &Some(GotoDefinitionResponse::Array(Vec::new())),

+                        );

+                        sender.send(RawMessage::Response(resp))?;

+                        continue;

+                    }

+                    Err(req) => req,

+                };

+                // ...

+            }

+            RawMessage::Response(_resp) => (),

+            RawMessage::Notification(_not) => (),

+        }

+    }

+    Ok(())

+}