Skip to content

Commit

Permalink
test
Browse files Browse the repository at this point in the history
  • Loading branch information
sphuber committed Oct 25, 2024
1 parent ca2d99f commit 8ae25c6
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions tests/test_stdin_socket.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,15 +18,14 @@ def run_process(test_file):
return 1


@tornado.gen.coroutine
def read_from_stream(stream, timeout=5):
start = time.time()
while time.time() - start < timeout:
try:
data = stream.get_nowait()
raise tornado.gen.Return(data['data'].decode('utf-8'))
except Empty:
yield tornado_sleep(.1)
yield from tornado_sleep(.1)
raise TimeoutException('Timeout reading queue')


Expand Down

0 comments on commit 8ae25c6

Please sign in to comment.