equal
deleted
inserted
replaced
38 |
38 |
39 def _forwardoutput(ui, pipe, warn=False): |
39 def _forwardoutput(ui, pipe, warn=False): |
40 """display all data currently available on pipe as remote output. |
40 """display all data currently available on pipe as remote output. |
41 |
41 |
42 This is non blocking.""" |
42 This is non blocking.""" |
43 if pipe: |
43 if pipe and not pipe.closed: |
44 s = procutil.readpipe(pipe) |
44 s = procutil.readpipe(pipe) |
45 if s: |
45 if s: |
46 display = ui.warn if warn else ui.status |
46 display = ui.warn if warn else ui.status |
47 for l in s.splitlines(): |
47 for l in s.splitlines(): |
48 display(_(b"remote: "), l, b'\n') |
48 display(_(b"remote: "), l, b'\n') |