subscription = source.subscribe(
    lambda {|child|

        child.to_a.subscribe(
            lambda {|x|