From 71cff0ee10d596b0b8f5648e6acdbb3e5a4c5bcd Mon Sep 17 00:00:00 2001 From: yomguy Date: Wed, 26 Sep 2012 17:19:19 +0200 Subject: [PATCH] simplify streamer --- telemeta/views/core.py | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/telemeta/views/core.py b/telemeta/views/core.py index dc24a4fc..d57490ea 100644 --- a/telemeta/views/core.py +++ b/telemeta/views/core.py @@ -106,16 +106,15 @@ def render(request, template, data = None, mimetype = None): return render_to_response(template, data, context_instance=RequestContext(request), mimetype=mimetype) -def stream_from_processor(__decoder, __processor, __flag, metadata=None): +def stream_from_processor(_decoder, _proc, _flag, metadata=None): if metadata: - __processor.set_metadata(metadata) - while True: - __frames, __eodproc = __processor.process(*__decoder.process()) - if __eodproc or not len(__frames): - __flag.value = True - __flag.save() - break - yield __processor.chunk + _proc.set_metadata(metadata) + _eod = False + while not _eod: + _frames, _eod = _proc.process(*_decoder.process()) + yield _proc.chunk + _flag.value = True + _flag.save() def stream_from_file(__file): chunk_size = 0x100000 -- 2.39.5