Skip to content
Snippets Groups Projects
Commit 4d42a5fb authored by Manuel Jacob's avatar Manuel Jacob
Browse files

worker: add docstring to _blockingreader

parent 5d28246b
No related branches found
No related tags found
2 merge requests!168branching: merge default into stable,!125worker.py improvements
......@@ -69,6 +69,13 @@
class _blockingreader:
"""Wrap unbuffered stream such that pickle.load() works with it.
pickle.load() expects that calls to read() and readinto() read as many
bytes as requested. On EOF, it is fine to read fewer bytes. In this case,
pickle.load() raises an EOFError.
"""
def __init__(self, wrapped):
self._wrapped = wrapped
......@@ -94,7 +101,7 @@
def readline(self):
return self._wrapped.readline()
# issue multiple reads until size is fulfilled
# issue multiple reads until size is fulfilled (or EOF is encountered)
def read(self, size=-1):
if size < 0:
return self._wrapped.readall()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment