|
18 | 18 | //! let (receiver, sender, io_threads) = stdio_transport(); |
19 | 19 | //! gen_lsp_server::run_server( |
20 | 20 | //! ServerCapabilities::default(), |
21 | | -//! receiver, |
22 | | -//! sender, |
| 21 | +//! &receiver, |
| 22 | +//! &sender, |
23 | 23 | //! main_loop, |
24 | 24 | //! )?; |
25 | 25 | //! io_threads.join()?; |
@@ -94,14 +94,14 @@ pub use { |
94 | 94 | /// request. |
95 | 95 | pub fn run_server( |
96 | 96 | caps: ServerCapabilities, |
97 | | - receiver: Receiver<RawMessage>, |
98 | | - sender: Sender<RawMessage>, |
| 97 | + receiver: &Receiver<RawMessage>, |
| 98 | + sender: &Sender<RawMessage>, |
99 | 99 | server: impl FnOnce(InitializeParams, &Receiver<RawMessage>, &Sender<RawMessage>) -> Result<()>, |
100 | 100 | ) -> Result<()> { |
101 | 101 | info!("lsp server initializes"); |
102 | | - let params = initialize(&receiver, &sender, caps)?; |
| 102 | + let params = initialize(receiver, sender, caps)?; |
103 | 103 | info!("lsp server initialized, serving requests"); |
104 | | - server(params, &receiver, &sender)?; |
| 104 | + server(params, receiver, sender)?; |
105 | 105 | info!("lsp server waiting for exit notification"); |
106 | 106 | match receiver.recv() { |
107 | 107 | Some(RawMessage::Notification(n)) => n |
|
0 commit comments