From bc49523c99b2116646419f86532e88c3a058f382 Mon Sep 17 00:00:00 2001 From: Mikahael <54455412+Mikahael@users.noreply.github.com> Date: Sun, 25 Feb 2024 23:59:57 +0530 Subject: [PATCH] Delete nbstreamreader.py --- nbstreamreader.py | 39 --------------------------------------- 1 file changed, 39 deletions(-) delete mode 100644 nbstreamreader.py diff --git a/nbstreamreader.py b/nbstreamreader.py deleted file mode 100644 index bcffcbb..0000000 --- a/nbstreamreader.py +++ /dev/null @@ -1,39 +0,0 @@ -from threading import Thread -from queue import Queue, Empty - -class NonBlockingStreamReader: - - def __init__(self, stream): - ''' - stream: the stream to read from. - Usually a process' stdout or stderr. - ''' - - self._s = stream - self._q = Queue() - - def _populateQueue(stream, queue): - ''' - Collect lines from 'stream' and put them in 'quque'. - ''' - - while True: - line = stream.readline() - if line: - queue.put(line) - else: - raise UnexpectedEndOfStream - - self._t = Thread(target = _populateQueue, - args = (self._s, self._q)) - self._t.daemon = True - self._t.start() #start collecting lines from the stream - - def readline(self, timeout = None): - try: - return self._q.get(block = timeout is not None, - timeout = timeout) - except Empty: - return None - -class UnexpectedEndOfStream(Exception): pass \ No newline at end of file