Sha256: c6a253e5e0c723af5f6156ef6051c688d24b53b26385d459c1545b060bc2d7d7
Contents?: true
Size: 394 Bytes
Versions: 35
Compression:
Stored size: 394 Bytes
Contents
require 'arc-furnace/filter'
module ArcFurnace
class BlockFilter < Filter
private_attr_reader :block
def initialize(source:, block:)
raise 'Must specify a block' if block.nil?
@block = block
super(source: source)
end
def filter(row)
if block.arity == 2
block.call(row, params)
else
block.call(row)
end
end
end
end
Version data entries
35 entries across 35 versions & 1 rubygems