Sha256: 14b7fc8eb0455371014f8e8736c30d2d3428ad591df2a79df3d2b8d8d59008af
Contents?: true
Size: 1.59 KB
Versions: 22
Compression:
Stored size: 1.59 KB
Contents
module Bmg
module Relation
class Spied
include Operator::Unary
def initialize(operand, spy)
@operand = operand
@spy = spy
end
protected
attr_reader :spy
public
def type
operand.type
end
def type=(type)
operand.type = type
end
protected :type=
def each(&bl)
return enum_for(:each) unless bl
if spy.respond_to?(:measure)
spy.measure(self) do
operand.each(&bl)
end
else
spy.call(self)
operand.each(&bl)
end
end
def count
if spy.respond_to?(:measure)
spy.measure(self) do
operand.count
end
else
spy.call(self)
operand.count
end
end
def to_ast
[ :spied, operand.to_ast, spy ]
end
public ### algebra
Algebra.public_instance_methods(false).each do |m|
next if [:spied, :unspied].include?(m)
define_method(m) do |*args, &bl|
args = args.map{|a| a.respond_to?(:unspied) ? a.unspied : a }
operand.send(m, *args, &bl).spied(spy)
end
end
def unspied
operand
end
public ### update
def insert(*args, &bl)
operand.insert(*args, &bl)
end
def delete(*args, &bl)
operand.delete(*args, &bl)
end
def update(*args, &bl)
operand.update(*args, &bl)
end
protected ### inspect
def args
[ spy ]
end
end # class Spied
end # module Relation
end # module Bmg
Version data entries
22 entries across 22 versions & 1 rubygems