Add SimpleEngine.communicate

niklasf · Mar 21, 2019 · 5a3dffb · 5a3dffb
1 parent aef388c
commit 5a3dffb
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/chess/engine.py b/chess/engine.py
@@ -2222,6 +2222,12 @@ def _get():
             future = asyncio.run_coroutine_threadsafe(_get(), self.protocol.loop)
         return future.result()
 
+    def communicate(self, command_factory):
+        with self._not_shut_down():
+            coro = self.protocol.communicate(command_factory)
+            future = asyncio.run_coroutine_threadsafe(coro, self.protocol.loop)
+        return future.result()
+
     def configure(self, options):
         with self._not_shut_down():
             coro = asyncio.wait_for(self.protocol.configure(options), self.timeout)