2010-04-19 20:22:54 +02:00
|
|
|
|
|
|
|
class Functional
|
|
|
|
include Enumerable
|
|
|
|
|
|
|
|
def self.method_missing meth, *args, &exe
|
|
|
|
self.new.send meth, *args, &exe
|
|
|
|
end
|
|
|
|
|
2010-04-20 16:50:59 +02:00
|
|
|
def push_method meth, *args, &exe
|
|
|
|
@stack.push [meth, exe]+args
|
2010-04-19 20:22:54 +02:00
|
|
|
self
|
|
|
|
end
|
|
|
|
|
|
|
|
def initialize obj = nil, func = nil, *args
|
|
|
|
@stack, @obj, @func, @args = [], obj, func, args
|
|
|
|
end
|
|
|
|
|
|
|
|
def collect &exe
|
2010-04-20 16:50:59 +02:00
|
|
|
push_method :collect, &exe
|
2010-04-19 20:22:54 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
# map/reduce?
|
|
|
|
def map &exe
|
2010-04-20 16:50:59 +02:00
|
|
|
push_method :map, &exe
|
2010-04-19 21:22:30 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
# map/reduce?
|
|
|
|
def reduce &exe
|
|
|
|
raise "Reserved for MapReduce."
|
2010-04-19 20:22:54 +02:00
|
|
|
end
|
2010-04-19 21:08:49 +02:00
|
|
|
|
2010-04-19 20:22:54 +02:00
|
|
|
def select &exe
|
2010-04-20 16:50:59 +02:00
|
|
|
push_method :select, &exe
|
2010-04-19 20:22:54 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
def delete_if &exe
|
2010-04-20 16:50:59 +02:00
|
|
|
push_method :delete_if, &exe
|
|
|
|
end
|
|
|
|
|
|
|
|
def compact
|
|
|
|
push_method :compact
|
|
|
|
end
|
|
|
|
|
|
|
|
def together init, &exe
|
|
|
|
push_method :together, init, &exe
|
2010-04-19 20:22:54 +02:00
|
|
|
end
|
|
|
|
|
2010-04-19 21:22:30 +02:00
|
|
|
def each &exe
|
|
|
|
return self unless exe
|
2010-04-20 16:50:59 +02:00
|
|
|
callstack = exe
|
|
|
|
@stack.reverse.each do |a|
|
|
|
|
m, e = *a[0..1]
|
|
|
|
pre = callstack
|
|
|
|
callstack = case m
|
|
|
|
when :collect then lambda {|val| pre.call e.call( val) }
|
|
|
|
when :map then lambda {|val| e.call( val).each &pre }
|
|
|
|
when :select then lambda {|val| pre.call val if e.call val }
|
|
|
|
when :delete_if then lambda {|val| pre.call val unless e.call val }
|
|
|
|
when :compact then lambda {|val| pre.call val if val }
|
|
|
|
when :together
|
|
|
|
buf = a[2]
|
|
|
|
lambda {|val| if e.call val then pre.call buf; buf = a[2]+val else buf += val end }
|
|
|
|
else
|
|
|
|
$stderr.puts "Whats that? #{m.inspect}"
|
|
|
|
callstack
|
|
|
|
end
|
|
|
|
end
|
|
|
|
@obj.send @func||:each, *@args, &callstack
|
2010-04-19 20:22:54 +02:00
|
|
|
end
|
|
|
|
end
|