diff --git a/mesonbuild/mtest.py b/mesonbuild/mtest.py index 4c8cb82db..31349eabd 100644 --- a/mesonbuild/mtest.py +++ b/mesonbuild/mtest.py @@ -1120,15 +1120,13 @@ async def read_decode(reader: asyncio.StreamReader, console_mode: ConsoleUser) - # Extract lines out of the StreamReader. Print them # along the way if requested, and at the end collect # them all into a future. -async def read_decode_lines(reader: asyncio.StreamReader, q: 'asyncio.Queue[T.Optional[str]]', - console_mode: ConsoleUser) -> str: +async def read_decode_lines(reader: asyncio.StreamReader, + q: 'asyncio.Queue[T.Optional[str]]') -> str: stdo_lines = [] try: while not reader.at_eof(): line = decode(await reader.readline()) stdo_lines.append(line) - if console_mode is ConsoleUser.STDOUT: - print(line, end='', flush=True) await q.put(line) return ''.join(stdo_lines) except asyncio.CancelledError: @@ -1217,9 +1215,9 @@ class TestSubprocess: self.postwait_fn = postwait_fn # type: T.Callable[[], None] self.all_futures = [] # type: T.List[asyncio.Future] - def stdout_lines(self, console_mode: ConsoleUser) -> T.AsyncIterator[str]: + def stdout_lines(self) -> T.AsyncIterator[str]: q = asyncio.Queue() # type: asyncio.Queue[T.Optional[str]] - decode_coro = read_decode_lines(self._process.stdout, q, console_mode) + decode_coro = read_decode_lines(self._process.stdout, q) self.stdo_task = asyncio.ensure_future(decode_coro) return queue_iter(q) @@ -1464,7 +1462,7 @@ class SingleTestRunner: parse_task = None if self.runobj.needs_parsing: - parse_coro = self.runobj.parse(harness, p.stdout_lines(self.console_mode)) + parse_coro = self.runobj.parse(harness, p.stdout_lines()) parse_task = asyncio.ensure_future(parse_coro) stdo_task, stde_task = p.communicate(self.console_mode)