Module: Stages::Sugar
- Defined in:
- lib/sugar.rb
Instance Method Summary collapse
- #cache(*args, &block) ⇒ Object
- #each(*args, &block) ⇒ Object
- #emit(*args, &block) ⇒ Object
- #exhaust_and_count(*args, &block) ⇒ Object
- #feeder(*args, &block) ⇒ Object
- #group(*args, &block) ⇒ Object
- #limit(*args, &block) ⇒ Object
- #map(*args, &block) ⇒ Object
- #run_until_exhausted(*args, &block) ⇒ Object
- #select(*args, &block) ⇒ Object
- #unique(*args, &block) ⇒ Object
- #wrap(*args, &block) ⇒ Object
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 |