[downloader/fragment] Commit part file after each fragment

In order to obtain correct resume_len on next iteration
This commit is contained in:
Sergey M․ 2017-12-02 21:15:45 +07:00
parent 603fc4e0ea
commit 593f2f7989
No known key found for this signature in database
GPG key ID: 2C393E0F18A9236D

View file

@ -107,6 +107,7 @@ class FragmentFD(FileDownloader):
def _append_fragment(self, ctx, frag_content): def _append_fragment(self, ctx, frag_content):
try: try:
ctx['dest_stream'].write(frag_content) ctx['dest_stream'].write(frag_content)
ctx['dest_stream'].flush()
finally: finally:
if self.__do_ytdl_file(ctx): if self.__do_ytdl_file(ctx):
self._write_ytdl_file(ctx) self._write_ytdl_file(ctx)