X-Git-Url: http://dolda2000.com/gitweb/?a=blobdiff_plain;f=wrw%2Fdispatch.py;h=2ece0931513acb4ebcbbfe82efc639dce87ec2ca;hb=b0f95b219e2f9aea9f81d696adbfaaa0e41a6eaf;hp=10cc2f6ef8014d451e330ebdf9119eee00bf3627;hpb=10ba659d32518d2d09b12ada86a380798b378fe7;p=wrw.git diff --git a/wrw/dispatch.py b/wrw/dispatch.py index 10cc2f6..2ece093 100644 --- a/wrw/dispatch.py +++ b/wrw/dispatch.py @@ -16,40 +16,16 @@ def mangle(result): return result return [str(result)] -class iterproxy(object): - # Makes sure iter(real).next() is called immediately, in order to - # let generator code run. - def __init__(self, real): - self.bk = real - self.bki = iter(real) - self._next = [None] - self.__next__() - - def __iter__(self): - return self - - def __next__(self): - if self._next is None: - raise StopIteration() - ret = self._next[0] - try: - self._next[:] = [self.bki.__next__()] - except StopIteration: - self._next = None - return ret - - def close(self): - if hasattr(self.bk, "close"): - self.bk.close() - def defaulterror(req, excinfo): from . import resp traceback.print_exception(*excinfo) + sys.stderr.flush() raise resp.httperror(500) def wraphandler(handler, excinfo): def wrapped(req): return handler(req, excinfo) + wrapped.__wrapped__ = handler return wrapped errorhandler = env.var(defaulterror) @@ -60,7 +36,7 @@ def handle(req, startreq, handler): resp = [""] while True: try: - resp = iterproxy(handler(req)) + resp = handler(req) break except restart as i: handler = i.handle