8c35227c6e3c4a6b85d2f719c9a62031f5e4ca6f,src/python/pants/java/nailgun_io.py,,_pipe,#Any#,19

Before Change

@contextmanager
def _pipe(isatty):
  r_fd, w_fd = os.openpty() if isatty else os.pipe()
  try:
    yield os.fdopen(r_fd, "r"), os.fdopen(w_fd, "w")
  finally:
    os.close(r_fd)
    os.close(w_fd)


class NailgunStreamStdinReader(threading.Thread):
  Reads Nailgun "stdin" chunks on a socket and writes them to an output file-like.

  Because a Nailgun server only ever receives STDIN and STDIN_EOF ChunkTypes after initial

After Change

@contextmanager
def _pipe(isatty):
  r_fd, w_fd = os.openpty() if isatty else os.pipe()
  with os.fdopen(r_fd, "r") as r, os.fdopen(w_fd, "w") as w:
    yield (r, w)


class _StoppableDaemonThread(threading.Thread):
  A stoppable daemon threading.Thread.

  JOIN_TIMEOUT = 3

Instances