Set pipe input object as responding to CPR by default

Author: vxgmichel

prompt_toolkit/input/defaults.py

@@ -43,16 +43,16 @@ def create_input(
  return Vt100Input(stdin)
 
 
-def create_pipe_input() -> Input:
+def create_pipe_input(responds_to_cpr: bool = True) -> Input:
  """
  Create an input pipe.
  This is mostly useful for unit testing.
  """
  if is_windows():
  from .win32_pipe import Win32PipeInput
 
- return Win32PipeInput()
+ return Win32PipeInput(responds_to_cpr=responds_to_cpr)
  else:
  from .posix_pipe import PosixPipeInput
 
- return PosixPipeInput()
+ return PosixPipeInput(responds_to_cpr=responds_to_cpr)

prompt_toolkit/input/posix_pipe.py

@@ -23,7 +23,8 @@ class PosixPipeInput(Vt100Input):
 
  _id = 0
 
- def __init__(self, text: str = "") -> None:
+ def __init__(self, text: str = "", responds_to_cpr: bool = True) -> None:
+ self._responds_to_cpr = True
  self._r, self._w = os.pipe()
 
  class Stdin:
@@ -44,7 +45,7 @@ def fileno(stdin) -> int:
 
  @property
  def responds_to_cpr(self) -> bool:
- return False
+ return self._responds_to_cpr
 
  def send_bytes(self, data: bytes) -> None:
  os.write(self._w, data)

prompt_toolkit/input/win32_pipe.py

@@ -29,7 +29,7 @@ class Win32PipeInput(_Win32InputBase):
 
  _id = 0
 
- def __init__(self) -> None:
+ def __init__(self, responds_to_cpr: bool = True) -> None:
  super().__init__()
  # Event (handle) for registering this input in the event loop.
  # This event is set when there is data available to read from the pipe.
@@ -39,6 +39,7 @@ def __init__(self) -> None:
  self._event = create_win32_event()
 
  self._closed = False
+ self._responds_to_cpr = responds_to_cpr
 
  # Parser for incoming keys.
  self._buffer: List[KeyPress] = [] # Buffer to collect the Key objects.
@@ -105,7 +106,7 @@ def flush_keys(self) -> List[KeyPress]:
 
  @property
  def responds_to_cpr(self) -> bool:
- return False
+ return self._responds_to_cpr
 
  def send_bytes(self, data: bytes) -> None:
  " Send bytes to the input. "