Sha256: 82abef98b8c24a2460f679dc1c1929782c1b4deba57eefa3c9f2be7d565cb28f
Contents?: true
Size: 309 Bytes
Versions: 22
Compression:
Stored size: 309 Bytes
Contents
require 'wukong/streamer/list_reducer'
module Wukong
module Streamer
#
# Emit each unique key and the count of its occurrences
#
class SetReducer < Wukong::Streamer::ListReducer
# Begin with an empty set
def start! *args
self.values = Set.new
end
end
end
end
Version data entries
22 entries across 22 versions & 2 rubygems