subscription = source.subscribe(
    lambda {|child|
        child.to_a.subscribe(
            lambda {|x|
                puts 'Child Next: ' + x.to_s