lib/taps/data_stream.rb in taps2-0.6.6 vs lib/taps/data_stream.rb in taps2-0.6.7

- old
+ new

@@ -274,12 +274,9 @@ (chunksize * 3).ceil end end def load_buffer(chunksize) - # make sure BasicObject is not polluted by subsequent requires - Sequel::BasicObject.remove_methods! - num = 0 loop do limit = calc_limit(chunksize) # we have to use local variables in order for the virtual row filter to work correctly key = primary_key