Fix indentation on the StreamReader.
This commit is contained in:
parent
959016a6eb
commit
1af0cb3341
1 changed files with 12 additions and 12 deletions
|
@ -22,20 +22,20 @@ logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
class SocketReader(object):
|
class SocketReader(object):
|
||||||
def __init__(self, fp):
|
def __init__(self, fp):
|
||||||
self._fp = fp
|
self._fp = fp
|
||||||
self.handlers = []
|
self.handlers = []
|
||||||
|
|
||||||
def add_handler(self, handler):
|
def add_handler(self, handler):
|
||||||
self.handlers.append(handler)
|
self.handlers.append(handler)
|
||||||
|
|
||||||
def read(self, n=-1):
|
def read(self, n=-1):
|
||||||
buf = self._fp.read(n)
|
buf = self._fp.read(n)
|
||||||
if not buf:
|
if not buf:
|
||||||
return ''
|
return ''
|
||||||
for handler in self.handlers:
|
for handler in self.handlers:
|
||||||
handler(buf)
|
handler(buf)
|
||||||
return buf
|
return buf
|
||||||
|
|
||||||
|
|
||||||
def require_completion(f):
|
def require_completion(f):
|
||||||
|
|
Reference in a new issue