enable black on fdroidserver/asynchronousfilereader/__init__.py
This commit is contained in:
parent
2273d8203b
commit
32ea4ef19a
@ -12,6 +12,7 @@ Copyright (c) 2014 Stefaan Lippens
|
|||||||
__version__ = '0.2.1'
|
__version__ = '0.2.1'
|
||||||
|
|
||||||
import threading
|
import threading
|
||||||
|
|
||||||
try:
|
try:
|
||||||
# Python 2
|
# Python 2
|
||||||
from Queue import Queue
|
from Queue import Queue
|
||||||
@ -22,7 +23,7 @@ except ImportError:
|
|||||||
|
|
||||||
class AsynchronousFileReader(threading.Thread):
|
class AsynchronousFileReader(threading.Thread):
|
||||||
"""Helper class to implement asynchronous reading of a file in a separate thread.
|
"""Helper class to implement asynchronous reading of a file in a separate thread.
|
||||||
|
|
||||||
Pushes read lines on a queue to be consumed in another thread.
|
Pushes read lines on a queue to be consumed in another thread.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
@ -53,4 +54,3 @@ class AsynchronousFileReader(threading.Thread):
|
|||||||
"""Get currently available lines."""
|
"""Get currently available lines."""
|
||||||
while not self.queue.empty():
|
while not self.queue.empty():
|
||||||
yield self.queue.get()
|
yield self.queue.get()
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user