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))