Contents

module Wukong
  module Streamer
    #
    # emit only some records, as dictated by the #emit? method
    #
    # This is a mixin: including this module in your streamer
    # implements its +#process+ method.
    #
    module Filter
      #
      # Filter out a subset of record/lines
      #
      # Subclass and re-define the emit? method
      #
      def process *record
        yield record if emit?(*record)
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
wukong-3.0.0.pre	old/wukong/streamer/filter.rb
wukong-2.0.2	lib/wukong/streamer/filter.rb
wukong-2.0.1	lib/wukong/streamer/filter.rb
wukong-2.0.0	lib/wukong/streamer/filter.rb