Rx::Observable.from(s).subscribe(
  lambda {|x|
    puts 'Next: ' + x.to_s
  },
  lambda {|err|