def create_observer(tag)
    Rx::Observer.create(
        lambda {|x|
            puts 'Next: ' + tag + x.to_s
        },