Module: Stages::Sugar

Defined in:
lib/sugar.rb

Instance Method Summary collapse

Instance Method Details

#cache(*args, &block) ⇒ Object



39
40
41
# File 'lib/sugar.rb', line 39

def cache(*args, &block)
  Cache.new(*args, &block)
end

#each(*args, &block) ⇒ Object



7
8
9
# File 'lib/sugar.rb', line 7

def each(*args, &block)
  Each.new(*args, &block)
end

#emit(*args, &block) ⇒ Object



35
36
37
# File 'lib/sugar.rb', line 35

def emit(*args, &block)
  Emit.new(*args, &block)
end

#exhaust_and_count(*args, &block) ⇒ Object



27
28
29
# File 'lib/sugar.rb', line 27

def exhaust_and_count(*args, &block)
  ExhaustCount.new(*args, &block)
end

#feeder(*args, &block) ⇒ Object



43
44
45
# File 'lib/sugar.rb', line 43

def feeder(*args, &block)
  Feeder.new(*args, &block)
end

#group(*args, &block) ⇒ Object



31
32
33
# File 'lib/sugar.rb', line 31

def group(*args, &block)
  Count.new
end

#limit(*args, &block) ⇒ Object



47
48
49
# File 'lib/sugar.rb', line 47

def limit(*args, &block)
  Limit.new(*args, &block)
end

#map(*args, &block) ⇒ Object



11
12
13
# File 'lib/sugar.rb', line 11

def map(*args, &block)
  Map.new(*args, &block)
end

#run_until_exhausted(*args, &block) ⇒ Object



23
24
25
# File 'lib/sugar.rb', line 23

def run_until_exhausted(*args, &block)
  Exhaust.new(*args, &block)
end

#select(*args, &block) ⇒ Object



3
4
5
# File 'lib/sugar.rb', line 3

def select(*args, &block)
  Select.new(*args, &block)
end

#unique(*args, &block) ⇒ Object



19
20
21
# File 'lib/sugar.rb', line 19

def unique(*args, &block)
  Unique.new(*args, &block)
end

#wrap(*args, &block) ⇒ Object



15
16
17
# File 'lib/sugar.rb', line 15

def wrap(*args, &block)
  Wrap.new(*args, &block)
end