from collections import namedtuple
-import contextlib
import datetime
import itertools
import re
self.in_sess = False
def update(self, capture):
- from functools import partial
-
if self.sync_tail:
new = self.sync_tail.intersect_right(capture.playlist)
if new:
def put_entry(self, entry, time = None):
if isinstance(entry, Segment):
while self.buffer:
- self.dest.put_entry(self.buffer.pop(0))
+ self.dest.put_entry(self.buffer.pop(0), time)
self.flushed = True
self.dest.put_entry(entry, time)
elif self.flushed and isinstance(entry, Endlist):