]> git.parisson.com Git - telemeta.git/commitdiff
simplify streamer
authoryomguy <yomguy@parisson.com>
Wed, 26 Sep 2012 15:19:19 +0000 (17:19 +0200)
committeryomguy <yomguy@parisson.com>
Wed, 26 Sep 2012 15:19:19 +0000 (17:19 +0200)
telemeta/views/core.py

index dc24a4fca6a666823f012de5542efe42c1597c73..d57490eacd01141167d46858800dc4c8bfaddc85 100644 (file)
@@ -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