refactor(langserver,jsonrpc): use concurrent.futures.Future to send request, make register_capabilities syncronous

Author: d-biehl

.vscode/launch.json

@@ -112,7 +112,8 @@
 				//"tests/robotcode/language_server/robotframework/parts/test_references.py"
 				//"./tests/robotcode/language_server/robotframework/parts/test_discovering.py::test_workspace_discovery"
 				//"tests/robotcode/language_server/robotframework/parts/test_document_highlight.py"
-				"tests/robotcode/utils/test_dataclasses.py::test_really_complex_data"
+				//"tests/robotcode/utils/test_dataclasses.py::test_really_complex_data"
+				"tests/robotcode/language_server/robotframework/parts/test_foldingrange.py"
 			],
 			"console": "integratedTerminal",
 			"justMyCode": false,

hatch.toml

@@ -16,7 +16,7 @@ only-include = ["src", "CHANGELOG.md"]
 dependencies = [
   "pytest",
   "pytest-html",
-  "pytest_asyncio",
+  "pytest_asyncio>=0.21,<0.23",
   # "pytest-regtest>=1.5.0",
   "pytest-cov",
   "mypy",

package-lock.json

@@ -1327,20 +1327,20 @@
   "devDependencies": {
     "@types/node": "^18.15.11",
     "@types/vscode": "^1.82.0",
-    "@typescript-eslint/eslint-plugin": "^6.12.0",
-    "@typescript-eslint/parser": "^6.12.0",
+    "@typescript-eslint/eslint-plugin": "^6.14.0",
+    "@typescript-eslint/parser": "^6.14.0",
     "@vscode/test-electron": "^2.3.8",
     "@vscode/vsce": "^2.22.0",
-    "eslint": "^8.54.0",
-    "eslint-config-prettier": "^9.0.0",
+    "eslint": "^8.55.0",
+    "eslint-config-prettier": "^9.1.0",
     "eslint-plugin-import": "^2.29.0",
     "eslint-plugin-jsx-a11y": "^6.8.0",
     "eslint-plugin-node": "^11.1.0",
     "eslint-plugin-prettier": "^5.0.1",
     "ovsx": "^0.8.3",
-    "prettier": "^3.1.0",
+    "prettier": "^3.1.1",
     "ts-loader": "^9.5.1",
-    "typescript": "^5.3.2",
+    "typescript": "^5.3.3",
     "webpack": "^5.89.0",
     "webpack-cli": "^5.1.4"
   }

package.json

@@ -125,3 +125,31 @@ def __init__(self, _func: Callable[_TParams, _TResult]) -> None:
 class event(EventDescriptorBase[_TParams, _TResult, Event[_TParams, _TResult]]):  # noqa: N801
     def __init__(self, _func: Callable[_TParams, _TResult]) -> None:
         super().__init__(_func, Event[_TParams, _TResult])
+
+
+class ThreadedEventResultIteratorBase(EventResultIteratorBase[_TParams, _TResult]):
+    def _notify(self, *__args: _TParams.args, **__kwargs: _TParams.kwargs) -> Iterator[_TResult]:
+        for method in set(self):
+            yield method(*__args, **__kwargs)
+
+
+class ThreadedEventIterator(ThreadedEventResultIteratorBase[_TParams, _TResult]):
+    def __call__(self, *__args: _TParams.args, **__kwargs: _TParams.kwargs) -> Iterator[_TResult]:
+        return self._notify(*__args, **__kwargs)
+
+
+class ThreadedEvent(ThreadedEventResultIteratorBase[_TParams, _TResult]):
+    def __call__(self, *__args: _TParams.args, **__kwargs: _TParams.kwargs) -> List[_TResult]:
+        return list(self._notify(*__args, **__kwargs))
+
+
+class threaded_event_iterator(  # noqa: N801
+    EventDescriptorBase[_TParams, _TResult, ThreadedEventIterator[_TParams, _TResult]]
+):
+    def __init__(self, _func: Callable[_TParams, _TResult]) -> None:
+        super().__init__(_func, ThreadedEventIterator[_TParams, _TResult])
+
+
+class threaded_event(EventDescriptorBase[_TParams, _TResult, ThreadedEvent[_TParams, _TResult]]):  # noqa: N801
+    def __init__(self, _func: Callable[_TParams, _TResult]) -> None:
+        super().__init__(_func, ThreadedEvent[_TParams, _TResult])

packages/core/src/robotcode/core/event.py

@@ -553,10 +553,10 @@ def send_request(
 
             self._sended_request[id] = SendedRequestEntry(result, return_type_or_converter)
 
-        request = JsonRPCRequest(id=id, method=method, params=params)
-        self.send_message(request)
+            request = JsonRPCRequest(id=id, method=method, params=params)
+            self.send_message(request)
 
-        return result
+            return result
 
     def send_request_async(
         self,