¿Cómo itera el objeto Ruby's Enumerator externamente sobre un iterador interno?

Question

Según la documentación de Ruby, el objeto Enumerator usa el método each (enumerar) si no se proporciona un método de destino para los métodos to_enum o enum_for. Ahora, tomemos el siguiente parche mono y su encuestador, como un ejemplo

o = Object.new 
def o.each 
    yield 1 
    yield 2 
    yield 3 
end 
e = o.to_enum 

loop do 
    puts e.next 
end 

Teniendo en cuenta que el objeto enumerador utiliza el método each de responder cuando next se llama, cómo hacer llamadas a la mirada each método similar, cada vez next se llama? ¿La clase Enumeartor carga todos los contenidos de o.each y crea una copia local para la enumeración? ¿O hay algún tipo de magia Ruby que cuelga las operaciones en cada declaración de rendimiento hasta que se llame al next en el enumerador?

Si se realiza una copia interna, ¿es una copia profunda? ¿Qué pasa con los objetos de E/S que podrían usarse para la enumeración externa?

Estoy usando Ruby 1.9.2.

Answer 1

No es exactamente mágico, pero es hermoso, no obstante. En lugar de hacer una copia de algún tipo, se usa Fiber para ejecutar primero each en el objeto enumerable de destino. Después de recibir el siguiente objeto de each, Fiber produce este objeto y, por lo tanto, devuelve el control a donde se reanudó inicialmente el Fiber.

Es hermoso porque este enfoque no requiere una copia u otra forma de "copia de seguridad" del objeto enumerable, como se podría imaginar obteniendo por ejemplo llamando al #to_a en el enumerable. La programación cooperativa con fibras permite cambiar contextos exactamente cuando es necesario sin la necesidad de mantener alguna forma de anticipación.

Todo sucede en el C code para Enumerator. Una versión de Ruby puro que mostraría más o menos el mismo comportamiento podría tener este aspecto:

class MyEnumerator 
    def initialize(enumerable) 
    @fiber = Fiber.new do 
     enumerable.each { |item| Fiber.yield item } 
    end 
    end 

    def next 
    @fiber.resume || raise(StopIteration.new("iteration reached an end")) 
    end 
end 

class MyEnumerable 
    def each 
    yield 1 
    yield 2 
    yield 3 
    end 
end 

e = MyEnumerator.new(MyEnumerable.new) 
puts e.next # => 1 
puts e.next # => 2 
puts e.next # => 3 
puts e.next # => StopIteration is raised