このコミットが含まれているのは:
n9k 2021-04-12 12:09:39 +00:00
コミット 0f19d20f31
1個のファイルの変更1行の追加1行の削除

ファイルの表示

@ -163,7 +163,7 @@ class ConcatenatedSegments:
# run this function after sending each segment
self.segment_hook = segment_hook or (lambda n: None)
# run this function before reading files; if it returns True, then stop
self.should_close_connection = should_close_connection
self.should_close_connection = should_close_connection or (lambda: None)
self.segments_dir = segments_dir
self.segments = SegmentsIterator(self.segments_dir,