606
606
def __init__(self, *args, **kwargs):
607
607
super(GCCHKCanonicalizingPacker, self).__init__(*args, **kwargs)
608
608
self._data_changed = False
610
610
def _exhaust_stream(self, source_vf, keys, message, vf_to_stream, pb_offset):
611
611
"""Create and exhaust a stream, but don't insert it.
613
613
This is useful to get the side-effects of generating a stream.
615
615
self.pb.update('scanning %s' % (message,), pb_offset)