diff --git a/endpoints/registry.py b/endpoints/registry.py index 0225b2415..24f08ddef 100644 --- a/endpoints/registry.py +++ b/endpoints/registry.py @@ -22,20 +22,20 @@ logger = logging.getLogger(__name__) class SocketReader(object): - def __init__(self, fp): - self._fp = fp - self.handlers = [] + def __init__(self, fp): + self._fp = fp + self.handlers = [] - def add_handler(self, handler): - self.handlers.append(handler) + def add_handler(self, handler): + self.handlers.append(handler) - def read(self, n=-1): - buf = self._fp.read(n) - if not buf: - return '' - for handler in self.handlers: - handler(buf) - return buf + def read(self, n=-1): + buf = self._fp.read(n) + if not buf: + return '' + for handler in self.handlers: + handler(buf) + return buf def require_completion(f):