Method: Streamer::Functors::Group#group

Defined in:
lib/streamer/functors/group.rb

#group ⇒ Object 



9
10
11
12
13
14
 
# File 'lib/streamer/functors/group.rb', line 9

def group
  group_key = options.fetch(:by)
  operand_key = options.fetch(:operand)
  operator = options.fetch(:operator).to_sym
  accumulate(list, group_key, operand_key, operator)
end