lib/rio/ops/stream/input.rb in rio-0.3.3 vs lib/rio/ops/stream/input.rb in rio-0.3.4

@@ -162,13 +162,18 @@
 
         protected
 
         def each_record_init_
         end
-
+        def handle_skipped
+          return self unless cx.has_key?('skip_args')
+          args = cx['skip_args'] || []
+          self.skiprecords(*args)
+        end
         def create_selrej()
           sel_args = cx['stream_sel']
           nosel_args = cx['stream_nosel']
+          handle_skipped
           selrej = RIO::Match::Record::SelRej.new(self,sel_args,nosel_args)
           [selrej,selrej.rangetops]
         end
 
         def check_passed_ranges(selrej,recno)