TRBOTMOFUGJJPDBFTAKDE25E6CN46M62T7SP7XXRLB2VFLVMAJIQC
buffer = []
the_buffer = []
for the_line in gen:
# print("pushing: ", the_line, end='')
heapq.heappush(the_buffer, the_line)
if len(the_buffer) == len_:
yield heapq.heappop(the_buffer)
# print("buffer_after: ", repr(the_buffer))
while the_buffer != []:
yield heapq.heappop(the_buffer)
# print("buffer_after: ", repr(the_buffer))