optimize stdio communication

Author: d-biehl

.vscode/launch.json

@@ -87,12 +87,16 @@
 			"module": "robotcode.debugger",
 			"justMyCode": false,
 			"args": [
-				"-p", "6612",
+				"-p",
+				"6612",
 				"-w",
 				"--",
-				"-d", "results",
-				"-P", "./lib",
-				"-P", "./resources",
+				"-d",
+				"results",
+				"-P",
+				"./lib",
+				"-P",
+				"./resources",
 				//"C:\\tmp\\robottest\\tests\\bdd_style.robot"
 				"."
 			]
@@ -119,14 +123,7 @@
 			"justMyCode": false,
 			"args": [
 				"--mode",
-				"stdio",
-				"--call-tracing",
-				"--log-config",
-				"log.ini"
-				//"--debug",
-				// "--debug-json-rpc",
-				// "--debug-json-rpc-data",
-				//"--debug-colored"
+				"stdio"
 			]
 		},
 		{
@@ -162,13 +159,17 @@
 			"args": [
 				"--mode",
 				"stdio",
+				"--log",
+				"--log-level",
+				"TRACE",
 				"--call-tracing",
-				"--log-config",
-				"log.ini"
-				//"--debug",
-				// "--debug-json-rpc",
-				// "--debug-json-rpc-data",
-				//"--debug-colored"
+				"--log-json-rpc",
+				"--log-json-rpc-data",
+				"--log-language-server",
+				"--log-language-server-parts",
+				"--log-robotframework",
+				"--log-asyncio",
+				"--debug-asyncio"
 			]
 		},
 		{

robotcode/jsonrpc2/server.py

@@ -183,15 +183,18 @@ def run_io_nonblocking() -> None:
 
             async def aio_readline(rfile: BinaryIO, protocol: asyncio.Protocol) -> None:
                 protocol.connection_made(transport)
-                stdio_executor = ThreadPoolExecutor(max_workers=1, thread_name_prefix="aio_readline")
-                with stdio_executor:
+
+                def run() -> None:
                     while (
                         self._stdio_stop_event is not None and not self._stdio_stop_event.is_set() and not rfile.closed
                     ):
-                        data = await self.loop.run_in_executor(
-                            stdio_executor, cast(io.BufferedReader, rfile).read1, 1000
-                        )
-                        protocol.data_received(data)
+                        if cast(io.BufferedReader, rfile).peek(1):
+                            data = cast(io.BufferedReader, rfile).read1(10000)
+
+                            self.loop.call_soon_threadsafe(protocol.data_received, data)
+
+                with ThreadPoolExecutor(max_workers=1, thread_name_prefix="aio_readline") as stdio_executor:
+                    await asyncio.wrap_future(stdio_executor.submit(run))
 
             self.loop.run_until_complete(aio_readline(transport.rfile, protocol))