dev

Author: marcin-usielski

moler/config/connections.py

@@ -196,6 +196,7 @@ def tcp_asyncio_in_thrd_conn(port, host='localhost', name=None, **kwargs):  # kw
 
 def _register_builtin_unix_connections(connection_factory, moler_conn_class):
     from moler.io.raw.terminal import ThreadedTerminal
+    from moler.io.raw.terminal_no_forkpty import ThreadedTerminalNoForkPTY
 
     def terminal_thd_conn_mt(name=None):
         # ThreadedTerminal works on unicode so moler_connection must do no encoding
@@ -212,6 +213,22 @@ def terminal_thd_conn_st(name=None):
         io_conn = ThreadedTerminal(moler_connection=mlr_conn)  # TODO: add name, logger
         return io_conn
 
+    def terminal_nofork_thd_conn_mt(name=None):
+        # ThreadedTerminal works on unicode so moler_connection must do no encoding
+        # mlr_conn = mlr_conn_no_encoding(moler_conn_class, name=name)
+        mlr_conn = mlr_conn_no_encoding_partial_clean_vt100(moler_conn_class, name=name)
+        io_conn = ThreadedTerminalNoForkPTY(moler_connection=mlr_conn)  # TODO: add name, logger
+        return io_conn
+
+    def terminal_nofork_thd_conn_st(name=None):
+        # ThreadedTerminal works on unicode so moler_connection must do no encoding
+        # mlr_conn = mlr_conn_no_encoding(moler_conn_class, name=name)
+        from moler.moler_connection_for_single_thread_runner import MolerConnectionForSingleThreadRunner
+        mlr_conn = mlr_conn_no_encoding_partial_clean_vt100(MolerConnectionForSingleThreadRunner, name=name)
+        io_conn = ThreadedTerminalNoForkPTY(moler_connection=mlr_conn)  # TODO: add name, logger
+        return io_conn
+
+
     # TODO: unify passing logger to io_conn (logger/logger_name)
     connection_factory.register_construction(io_type="terminal",
                                              variant="threaded",
@@ -228,6 +245,21 @@ def terminal_thd_conn_st(name=None):
                                              constructor=terminal_thd_conn_st)
 
 
+    # TODO: unify passing logger to io_conn (logger/logger_name)
+    connection_factory.register_construction(io_type="terminal_no_forkpty",
+                                             variant="threaded",
+                                             constructor=terminal_nofork_thd_conn_mt)  # Moler 2.0.0 will replace this to st
+
+    # TODO: unify passing logger to io_conn (logger/logger_name)
+    connection_factory.register_construction(io_type="terminal_no_forkpty",
+                                             variant="multi-threaded",
+                                             constructor=terminal_nofork_thd_conn_mt)
+
+    # TODO: unify passing logger to io_conn (logger/logger_name)
+    connection_factory.register_construction(io_type="terminal_no_forkpty",
+                                             variant="single-threaded",
+                                             constructor=terminal_nofork_thd_conn_st)
+
 def _register_builtin_py3_unix_connections(connection_factory, moler_conn_class):
     from moler.io.asyncio.terminal import AsyncioTerminal, AsyncioInThreadTerminal
 

moler/io/io_connection.py

@@ -129,7 +129,7 @@ def notify(self, callback: Callable, when: str) -> None:
 
     def subscribe_on_connection_made(self, subscriber: Callable) -> None:
         """
-        Adds subscriber to list of functions to call when conne`ction is open/established (also reopen after close)
+        Adds subscriber to list of functions to call when connection is open/established (also reopen after close)
         :param subscriber: reference to function to call when connection is open/established
         :return: None
         """

moler/io/raw/terminal.py

@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 __author__ = "Michal Ernst, Marcin Usielski, Tomasz Krol"
-__copyright__ = "Copyright (C) 2018-2025, Nokia"
+__copyright__ = "Copyright (C) 2018-2026, Nokia"
 __email__ = "[email protected], [email protected], [email protected]"
 
 import codecs