Sha256: 8729a64025a1b0f297540547c4bda504c17e2223a8dc2bb0ceaa966c958dbc28
Contents?: true
Size: 401 Bytes
Versions: 28
Compression:
Stored size: 401 Bytes
Contents
require 'arc-furnace/observer'
module ArcFurnace
class BlockObserver < Observer
private_attr_reader :block
def initialize(source:, block:)
raise 'Must specify a block' if block.nil?
@block = block
super(source: source)
end
def observe(row)
if block.arity == 2
block.call(row, params)
else
block.call(row)
end
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems