Method insert

plugins/lsps-plugin/src/core/transport.rs:68–72

(&self, id: String)

    }

    pub async fn insert(&self, id: String) -> oneshot::Receiver<Vec<u8>> {
        let (tx, rx) = oneshot::channel();
        self.inner.lock().await.insert(id, tx);
        rx
    }

    pub async fn complete(&self, id: &str, data: Vec<u8>) -> bool {
        if let Some(tx) = self.inner.lock().await.remove(id) {