Sha256: 4e10d26c16bcc6970767d20dbb048922347548255d47737158af1c06459e257c
Contents?: true
Size: 263 Bytes
Versions: 13
Compression:
Stored size: 263 Bytes
Contents
module ArcFurnace
class PassthroughSink < Sink
attr_reader :collection
def initialize(options = {})
@collection = Set.new
end
def finalize
collection.to_a
end
def row(object)
collection << object
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems